Functions — github.com/taskforcesh/bullmq

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

⨍ Functions 3,768◇ Types & classes 487↳ Endpoints 8

↓ 2 callersMethodgetScript

* Load a Lua script by name. */

php/src/Scripts.php:72

↓ 2 callersMethodgetWorkersCount

* Returns the current count of workers for the queue. * * getWorkersCount(): Promise<number> *

src/classes/queue-getters.ts:599

↓ 2 callersFunctionget_cluster_nodes

(client: Any)

python/bullmq/utils.py:67

↓ 2 callersMethodget_counts_per_priority

Return the number of jobs per priority for the provided priorities. Priorities are de-duplicated. The returned map is keyed by priority value.

rust/src/queue.rs:1170

↓ 2 callersMethodget_failed_count

Return the number of jobs in the `failed` state.

rust/src/queue.rs:1223

↓ 2 callersMethodget_next_job_nonblocking

Manually fetch the next job (non-blocking — returns None immediately if no job available).

rust/src/worker.rs:827

↓ 2 callersFunctionget_node_client

(node: Any)

python/bullmq/utils.py:90

↓ 2 callersMethodhGetAll

(key: string)

src/classes/node-redis-client.ts:91

↓ 2 callersMethodhSet

(key: string, data: Record<string, string | number>)

src/classes/node-redis-client.ts:94

↓ 2 callersFunctionhasLegacyRepeatableKeyShape

(key: string)

src/classes/job-scheduler.ts:45

↓ 2 callersMethodhasQueueMetaField

* Returns whether a queue metadata field exists.

src/interfaces/queue-backend.ts:708

↓ 2 callersMethodincrby

(key: string, increment: number)

src/classes/bun-redis-client.ts:1222

↓ 2 callersMethodinfo

()

src/classes/node-redis-client.ts:166

↓ 2 callersFunctionisBuffer

(value: unknown)

src/classes/valkey-glide-client.ts:70

↓ 2 callersMethodisClusterWithEmptyNodes

( client: BlockingClusterClient, )

src/classes/redis-connection.ts:590

↓ 2 callersMethodisCompleted

Returns true if the job has completed.

python/bullmq/job.py:152

↓ 2 callersMethodisDelayed

* @returns true if the job is delayed.

src/classes/job.ts:903

↓ 2 callersMethodisFailed

* @returns true if the job has failed.

src/classes/job.ts:896

↓ 2 callersMethodisInList

(self, list_name: str)

python/bullmq/job.py:188

↓ 2 callersMethodisJobScheduler

Return True if `job_scheduler_id` is a registered scheduler.

python/bullmq/queue.py:516

↓ 2 callersMethodisPaused

Returns true if the queue is currently paused.

python/bullmq/queue.py:97

↓ 2 callersFunctionisPossiblyMappedPath

(path: string)

src/commands/script-loader.ts:83

↓ 2 callersMethodisRunning

* * Checks if worker is currently running. * * @returns true if worker is running, false otherwise.

src/classes/worker.ts:1273

↓ 2 callersMethodisWaitingChildren

* @returns true if the job is waiting for children.

src/classes/job.ts:910

↓ 2 callersFunctionis_redis_cluster

(client: Any)

python/bullmq/utils.py:51

↓ 2 callersMethodkill

( child: Child, signal: 'SIGTERM' | 'SIGKILL' = 'SIGKILL', )

src/classes/child-pool.ts:106

↓ 2 callersMethodlLen

(key: string)

src/classes/node-redis-client.ts:127

↓ 2 callersMethodlRange

(key: string, start: number, end: number)

src/classes/node-redis-client.ts:126

↓ 2 callersFunctionloadMigrationSql

(file: string)

src/postgres/sql-loader.ts:49

↓ 2 callersMethodmake_script_context

Create a ScriptContext for jobs reconstructed by get_flow.

rust/src/flow_producer.rs:1117

↓ 2 callersFunctionmapSchedulerRow

* Maps a scheduler row to the Redis-compatible metadata hash (string values, * absent fields omitted) plus the next-run score, matching the shape the

src/postgres/postgres-queue-backend.ts:184

↓ 2 callersMethodmerge_job_options

(&self, opts: Option<JobOptions>)

rust/src/queue.rs:315

↓ 2 callersMethodmoveJobsToWait

* Move jobs to wait state (for retrying). * * @param string $state Source state * @param int $count Number of jobs to move * @para

php/src/Scripts.php:482

↓ 2 callersMethodmoveJobsToWaitArgs

(self, state: str, count: int, timestamp: int)

python/bullmq/scripts.py:656

↓ 2 callersMethodmoveJobsToWaitArgs

( state: FinishedStatus | 'delayed', count: number, timestamp: number, )

src/classes/redis-queue-backend.ts:1887

↓ 2 callersMethodmoveToActive

( token: string, name?: string, )

src/classes/worker.ts:788

↓ 2 callersMethodmoveToCompletedArgs

(self, job: Job, return_value: str, shouldRemove, token: str, fetchNext=True)

python/bullmq/scripts.py:774

↓ 2 callersMethodmoveToFailedArgs

(self, job: Job, failed_reason: str, shouldRemove, token: str, fetchNext=True, fields_to_update = None)

python/bullmq/scripts.py:778

↓ 2 callersMethodmoveToFinished

( jobId: string, args: (string | number | boolean | Buffer)[], )

src/classes/redis-queue-backend.ts:1199

↓ 2 callersMethodmoveToFinishedArgs

(self, job: Job, val: Any, propVal: str, shouldRemove, target, token: str, fetchNext=True, fields_to_u

python/bullmq/scripts.py:715

↓ 2 callersMethodmoveToFinishedArgs

( job: MinimalJob<T, R, N>, val: any, propVal: FinishedPropValAttribute, shouldRemove: undefin

src/classes/redis-queue-backend.ts:1129

↓ 2 callersMethodmove_to_finished

Internal: move job to completed or failed.

rust/src/job.rs:1111

↓ 2 callersMethodmove_to_wait

Move this job from the active state back to wait (or prioritized). Mirrors Node.js `Job.moveToWait`. Requires the job to have a script context (i.e.

rust/src/job.rs:1334

↓ 2 callersMethodmulti

()

src/interfaces/redis-client.ts:92

↓ 2 callersMethodnextJobFromJobData

(self, job_data: dict | None = None, job_id: str | None = None, limit_until: int = 0, delay_until: int

python/bullmq/worker.py:276

↓ 2 callersFunctionnext_cron_millis

Compute the next execution time for a cron pattern. Returns the next millisecond timestamp after `now_ms`.

rust/src/job_scheduler.rs:100

↓ 2 callersFunctionnoop_processor

()

rust/tests/convenience_methods_test.rs:20

↓ 2 callersFunctionnormalizeKeep

* Normalizes a `removeOnComplete`/`removeOnFail` option into the retention * params the move_to_completed/failed functions take: * - `true` → remove

src/postgres/postgres-queue-backend.ts:94

↓ 2 callersFunctionnormalizeScriptArgs

(args: any[])

src/classes/node-redis-client.ts:36

↓ 2 callersFunctionnormalizeScriptArgs

(args: any[])

src/classes/bun-redis-client.ts:40

↓ 2 callersFunctionnormalizeScriptArgs

(args: any[])

src/classes/valkey-glide-client.ts:101

↓ 2 callersFunctionnormalizeSortedSetReply

(reply: unknown, withScores = false)

src/classes/valkey-glide-client.ts:266

↓ 2 callersFunctionnow_ms

()

rust/tests/worker_options_test.rs:19

↓ 2 callersMethodnumQueued

* Returns the number of items that have already resolved but have not * yet been fetched by a consumer. * * @returns The number of resolved i

src/classes/async-fifo-queue.ts:147

↓ 2 callersMethodnumTotal

* Returns the total number of items currently tracked by the queue, * including both pending (in-flight) promises and resolved items that * have

src/classes/async-fifo-queue.ts:128

↓ 2 callersFunctionoptsFromJSON

(rawOpts: dict)

python/bullmq/job.py:369

↓ 2 callersMethodpack_add_args

Pack ARGV[1]: msgpack array matching the Lua script contract. Positions: [key_prefix, job_id, name, timestamp, parentKey, parentDepsKey, parent, repe

rust/src/flow_producer.rs:881

↓ 2 callersMethodpack_add_args

Pack ARGV[1]: msgpack array matching the Lua script contract. Positions: [key_prefix, job_id, name, timestamp, parentKey, parentDepsKey, parent, repe

rust/src/queue.rs:392

↓ 2 callersMethodpack_job_opts

Pack ARGV[3]: msgpack map of job options.

rust/src/flow_producer.rs:971

↓ 2 callersMethodpack_job_opts

Pack ARGV[3]: msgpack map of job options using the raw script keys.

rust/src/queue.rs:470

↓ 2 callersFunctionpack_move_to_active_opts

(token: &str, opts: &WorkerOptions)

rust/src/worker.rs:365

↓ 2 callersFunctionpack_move_to_finished_opts

( token: &str, opts: &WorkerOptions, job_opts: &JobOptions, attempts: u32, target: &str, )

rust/src/worker.rs:430

↓ 2 callersMethodpaginate

* Paginates a datastore set or hash, optionally fetching the jobs themselves.

src/interfaces/queue-backend.ts:666

↓ 2 callersFunctionparseObjectValues

(obj: { [key: string]: string; })

src/utils/index.ts:317

↓ 2 callersFunctionparse_scheduler_hash

Parse the result from the getJobScheduler Lua script.

rust/src/job_scheduler.rs:378

↓ 2 callersMethodpause

* Pauses the processing of the queue. * * @return void */

php/src/Queue.php:192

↓ 2 callersMethodpriority

The job priority.

rust/src/job.rs:252

↓ 2 callersMethodpriority

Job priority. Lower values are processed first; unset (or `0`) means the job is not prioritized and follows normal FIFO/LIFO ordering.

rust/src/queue.rs:2724

↓ 2 callersMethodprocessJob

( job: Job<DataType, ResultType, NameType, ProgressType>, token: string, fetchNextCallback = () =>

src/classes/worker.ts:984

↓ 2 callersMethodprocessor

(job, token)

python/tests/priority_test.py:78

↓ 2 callersMethodprogress

Current progress.

rust/src/job.rs:175

↓ 2 callersMethodqueueFromNode

* Helper factory method that creates a queue-like object * required to create jobs in any queue. * * @param node - The flow node containing t

src/classes/flow-producer.ts:612

↓ 2 callersMethodrateLimit

Overrides the rate limit to be active for the next jobs by writing the limiter key with a large value that expires after `exp

python/bullmq/queue.py:109

↓ 2 callersMethodreconnectBlocking

* Re-establishes the backend's blocking connection after an interrupt.

src/interfaces/queue-backend.ts:780

↓ 2 callersMethodreconnectCluster

( client: BlockingClusterClient, timeoutMs: number, )

src/classes/redis-connection.ts:642

↓ 2 callersMethodrecord

* Records a value for the gauge. * * @param value - the value to record * @param attributes - optional attributes to associate with this meas

src/interfaces/telemetry.ts:136

↓ 2 callersMethodrecordException

* recordException records an exception on the span. * * @param exception - exception to record * @param time - time to record the exception

src/interfaces/telemetry.ts:245

↓ 2 callersMethodrecord_job_counts_metric

Return job counts by state, invoking `recorder` once per `(state, count)`. Mirrors Node.js `Queue.recordJobCountsMetric`, which records gauge metrics

rust/src/queue.rs:1140

↓ 2 callersFunctionredact_url_userinfo

(url: &str)

rust/src/options.rs:118

↓ 2 callersMethodremoveChildDependency

* Removes the child→parent dependency for a not-yet-finished child. * @returns `true` if the dependency existed and was removed.

src/interfaces/queue-backend.ts:499

↓ 2 callersMethodremoveDeduplicationKey

* Removes a deduplication key if it still maps to the given job. * @returns `1` if removed, `0` otherwise.

src/interfaces/queue-backend.ts:505

↓ 2 callersMethodremoveRateLimitKey

* Removes the rate-limit key. * @returns The number of keys removed.

src/interfaces/queue-backend.ts:719

↓ 2 callersMethodremoveUnprocessedChildren

* Removes all unprocessed children of a job.

src/interfaces/queue-backend.ts:493

↓ 2 callersMethodremove_job

(&self, job_id: &str, remove_children: bool)

rust/src/queue.rs:1665

↓ 2 callersMethodremove_unprocessed_children

Remove all unprocessed children of a job. This removes children that are still in the dependencies set (not yet completed/failed). Active children ar

rust/src/queue.rs:1708

↓ 2 callersMethodrepeat_job_key

The scheduler ID that produced this job (if any).

rust/src/job.rs:191

↓ 2 callersFunctionresetBlockedConnection

* Resets a connection whose blocking command was abandoned by a watchdog. * * Under `maxRetriesPerRequest: null` IORedis silently re-queues and re-s

src/classes/redis-queue-backend.ts:108

↓ 2 callersMethodreset_job_channel

Drop the LISTEN connection so the next wait re-establishes it.

python/bullmq/backends/postgres_connection.py:261

↓ 2 callersMethodresume

Resumes the processing of this queue globally. The method reverses the pause operation by resuming the processing of the que

python/bullmq/queue.py:88

↓ 2 callersMethodresume

* Resumes the processing of the queue. * * @return void */

php/src/Queue.php:202

↓ 2 callersMethodretryIfFailed

( fn: () => Promise<T>, opts: { delayInMs: number; span?: Span; maxRetries?: number;

src/classes/worker.ts:1411

↓ 2 callersMethodretryJobs

* Retry all failed or completed jobs. * * @param array{count?: int, state?: string, timestamp?: int} $opts Options: * - count: Maximu

php/src/Queue.php:544

↓ 2 callersMethodrun

Start consuming events. Idempotent only in the sense that a second call while the loop is running raises; this mirrors Node's

python/bullmq/queue_events.py:110

↓ 2 callersMethodrun

()

src/classes/worker.ts:565

↓ 2 callersMethodrunCommand

(name: string, args: any[])

src/classes/node-redis-client.ts:452

↓ 2 callersMethodrunCommand

(name: string, args: any[])

src/classes/bun-redis-client.ts:634

↓ 2 callersMethodrunSerialized

( fn: (raw: ValkeyGlideRawClient) => Promise<T>, )

src/classes/valkey-glide-client.ts:413

↓ 2 callersFunctionrun_migrations

Bring the database schema up to the latest bundled migration. Runs inside a single transaction guarded by a per-schema advisory lock so concu

python/bullmq/backends/postgres_connection.py:105

↓ 2 callersMethodsAdd

(key: string, members: string[])

src/classes/node-redis-client.ts:134

↓ 2 callersMethodsMembers

(key: string)

src/classes/node-redis-client.ts:133

← previous next →601–700 of 3,768, ranked by callers