omni_worker

omnigres : Generalized worker pool

Overview

Packages

Source

pig build pkg omnigres;		# build rpm/deb

Install

Make sure PGDG and PIGSTY repo available:

pig repo add pgsql -u   # add both repo and update cache

Install this extension with pig:

pig install omnigres;		# install via package name, for the active PG version
pig install omni_worker;		# install by extension name, for the current active PG version

pig install omni_worker -v 18;   # install for PG 18
pig install omni_worker -v 17;   # install for PG 17
pig install omni_worker -v 16;   # install for PG 16
pig install omni_worker -v 15;   # install for PG 15
pig install omni_worker -v 14;   # install for PG 14

Create this extension with:

CREATE EXTENSION omni_worker;

Usage

omni_worker: Generalized worker pool

The omni_worker extension provides a generalized PostgreSQL worker pool that executes arbitrary workloads within individual backend contexts.

SQL Handler

The built-in SQL handler schedules SQL statement execution in background workers.

Fire-and-forget:

SELECT omni_worker.sql('INSERT INTO logs VALUES (now(), $1)');

Returns null immediately upon scheduling.

With timeout:

SELECT omni_worker.sql('VACUUM ANALYZE my_table', wait_ms => 1000);

Returns:

• true – Execution completed successfully
• false – Execution completed with failure
• null – Execution did not complete within the timeout

The SQL handler is enabled by default but can be disabled by removing its entry from the handlers table.