Block on the events stream and re-emit each entry.

Return the total number of nodes in a flow definition (root plus all descendant children).

Translate one stream entry into one (or two) emit calls.

Return a TCP port that is guaranteed to be closed at the moment the function returns. Binding to port 0 lets the OS pick a free port; we clos

Best-effort decode of a legacy `name:id:endDate:tz:pattern...` repeatable-job key. Mirrors `JobScheduler.keyToData` in the Node port. Fields t

* Materialize a lazily-created raw client (duplicate `rawFactory`). * Concurrent callers share the in-flight promise so the factory runs once.

Return True if `processor` declares a 3rd positional parameter (the `AbortSignal`). Falls back to False for builtins / C callables whose signa

Wake every `lock_renew_time / 2` ms and renew locks for any tracked job whose stored timestamp is older than half the renewal window.

Normalize a completed job's return value for jsonb storage. Most call paths now pass raw Python objects, but older/legacy callers may still p

Upsert the job scheduler that produced `job` so its next iteration is materialized. Most of the arguments are no longer strictly neede

Translate the numeric error code returned by the addJob Lua script into a descriptive Exception. Mirrors Node's `toFlowError`

Lazily ensure the connected Redis supports Streams (>= 5.0). Honours `skipVersionCheck` via the underlying RedisConnection.

Number of currently active jobs.

* Adds a promise to the queue. When it resolves, its value is enqueued * and, if a consumer is waiting via {@link fetch}, the next pending * pro

Add a delayed job to the queue

* Add a delayed job to the queue. * * @param Job $job * @param int $delay * @return mixed */

* Add a delayed job to a transaction. */

* addJob is a telemetry free version of the add method, useful in order to wrap it * with custom telemetry on subclasses. * * @param name - N

* Add a job to a transaction (for bulk operations). * * @param mixed $transaction The Predis transaction * @param Job $job * @retu

Add a job to the queue that is a parent

* Add a script path mapping. Allows includes of the form "<includes>/utils.lua" where `includes` is a user * defined path * @param name - the na

Add a prioritized job to the queue

* Add a prioritized job to the queue. * * @param Job $job * @param int $priority * @return mixed */

* Add a prioritized job to a transaction. */

Add a standard job to the queue

* Add a standard job to the queue. * * @param Job $job * @param int $timestamp * @return mixed */

* Add a standard job to a transaction. */

Internal: add a single job via the appropriate Lua script.

Add a leaf job (no children) to the pipeline.

Add a parent job to the pipeline using the addParentJob Lua script.

* Re-applies the remembered {@link listenClientName} to a freshly established * `LISTEN` client. Best-effort: discovery must never break the client

* Prepares a job to be passed to Sandbox. * @returns

Number of times the job has *started* processing (the `attemptsStarted` counter). Incremented each time a worker picks up the job.

* Adds `runCommand` and structured overrides to an ioredis ChainableCommander * so it satisfies {@link IRedisTransaction}.

Add ``n`` jobs using ``parallelism`` concurrent adders on one queue.

Benchmark: Adding jobs one by one (sequential).

Benchmark: Adding jobs in parallel batches (tokio::spawn).

Benchmark: Bulk adding jobs.

Benchmark: Processing jobs with a worker.

Build a Redis [`Client`] from connection options. When [`RedisConnectionOptions::tls_certs`] is set, the client is built with the supplied TLS certif

* Cancels the currently running job by aborting its signal. * @param reason - Optional reason for the cancellation

Abort the signals of all currently tracked jobs. Has no effect on jobs whose processors did not opt into the `signal` argument.

Cancel all active jobs.

Abort the `AbortSignal` for the given job, if one was created. Returns True if a controller was found and aborted, False otherwise. Mi

Change the delay of a delayed job. `delay` is the new delay in milliseconds from now.

Change the priority of a waiting job. `priority` - New priority value (0 = no priority). `lifo` - If true, use LIFO ordering within the same priority