Functions — github.com/taskforcesh/bullmq

CodeHub MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

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

MethodremoveOrphanedJobs

(count = 1000, limit = 0)

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

MethodremoveQueueMetaFields

(fields: string[])

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

MethodremoveQueueMetaFields

(fields: string[])

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

MethodremoveRateLimitKey

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

MethodremoveRateLimitKey

* Removes rate limit key.

src/classes/queue.ts:661

MethodremoveRateLimitKey

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

MethodremoveUnprocessedChildren

(jobId: string)

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

MethodremoveUnprocessedChildren

* Remove all children from this job that are not yet processed, * in other words that are in any other state than completed, failed or active. *

src/classes/job.ts:618

MethodremoveUnprocessedChildren

(jobId: string)

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

Methodremove_child_dependency

Remove a child's dependency from its parent. `job_id` - the child job ID `parent_key` - the fully qualified parent key (prefix:queue:parentId) Retur

rust/src/queue.rs:1563

Methodremove_debounce_key

Remove a debounce key unconditionally, returning the number of keys deleted (`0` or `1`). Deprecated:** use [`Queue::remove_deduplication_key`] inste

rust/src/queue.rs:2169

Methodremove_dependency_on_failure

Remove this child's dependency from the parent when it fails.

rust/src/options.rs:799

Methodremove_on_complete

Completed-job retention policy.

rust/src/queue.rs:2754

Methodremove_on_complete

Set the completed-job retention policy.

rust/src/options.rs:515

Methodremove_on_fail

Failed-job retention policy.

rust/src/queue.rs:2760

Methodremove_on_fail

Set the failed-job retention policy.

rust/src/options.rs:521

MethodreprocessJob

Reprocess a finished (failed/completed) job, moving it back to wait.

python/bullmq/backend.py:201

MethodreprocessJob

(self, job: "Job", state: str, opts: dict = {})

python/bullmq/backends/redis_backend.py:252

MethodreprocessJob

(self, job: "Job", state: str, opts: dict = {})

python/bullmq/backends/postgres_backend.py:538

MethodresetQueueKeys

(self, queue_name: str)

python/bullmq/scripts.py:39

FunctionresetRecommendedVersionWarning

tests/postgres/migration.test.ts:271

Functionresolves_unqualified_parent_queue_names

rust/src/keys.rs:285

Resumes processing of this worker (if paused).

python/bullmq/worker.py:619

Resume the worker.

rust/src/worker.rs:725

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

src/classes/queue.ts:539

* * Resumes processing of this worker (if paused).

src/classes/worker.ts:1224

* Attempts to retry the job. Only a job that has failed or completed can be retried. * * @param state - completed / failed * @param opts - op

src/classes/job.ts:1227

MethodretryFinishedJob

( job: MinimalJob<T, R, N>, state: 'failed' | 'completed', opts: RetryOptions = {}, )

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

MethodretryFinishedJob

* Attempts to reprocess a job * * @param job - The job to reprocess * @param state - The expected job state. If the job is not found * on

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

MethodretryFinishedJobs

( state?: FinishedStatus, count?: number, timestamp?: number, )

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

MethodretryFinishedJobs

( state: FinishedStatus = 'failed', count = 1000, timestamp = new Date().getTime(), )

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

(self, job_id: str, lifo: bool, token: str = "0", opts = {})

python/bullmq/scripts.py:307

Retry a failed/active job immediately by pushing it back to wait.

python/bullmq/backend.py:195

( self, job_id: str, lifo: bool, token: str = "0", opts: dict = {} )

python/bullmq/backends/redis_backend.py:247

(self, job_id: str, lifo: bool, token: str = "0", opts: dict = {})

python/bullmq/backends/postgres_backend.py:529

( jobId: string, lifo: boolean, token?: string, opts?: RetryJobOpts, )

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

( jobId: string, lifo: boolean, token = '0', opts: RetryJobOpts = {}, )

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

MethodretryJobs

Retry jobs that are in failed or completed state

python/bullmq/scripts.py:663

MethodretryJobs

Move up to ``count`` finished jobs of the given ``state`` back to wait. Returns a cursor; ``0`` when there are no more jobs to move.

python/bullmq/backend.py:219

MethodretryJobs

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

python/bullmq/backends/redis_backend.py:269

MethodretryJobs

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

python/bullmq/backends/postgres_backend.py:565

MethodretryJobs

* Retry all the failed or completed jobs. * * @param opts - An object with the following properties: * - count number to limit how many jo

src/classes/queue.ts:867

Methodretry_job_immediately

Retry a failed job by moving it back to the wait queue (no backoff).

rust/src/worker.rs:1923

Functionreturns_empty_when_no_match

rust/src/queue.rs:3000

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

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

MethodrunCommand

(name: string, args: any[])

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

MethodrunCommand

(name: string, args: any[])

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

MethodrunCommand

(name: string, args: any[])

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

MethodrunCommand

(name: string, args: any[])

src/interfaces/redis-client.ts:279

MethodrunStalledJobsCheck

python/bullmq/worker.py:569

Methodrun_main_driver

The single fetch-and-dispatch driver. Runs until `closing` is set. Fetches at most one job at a time. When the queue is empty (or waiting on a delaye

rust/src/worker.rs:889

Methodrun_retry_delay

Set the delay before retrying after a transient processing error.

rust/src/options.rs:527

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

(key: string, ...members: (string | number)[])

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

(key: string, ...members: (string | number)[])

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

Methodsanitize_job_types

Sanitize a list of job types: dedupe (preserving order) and add `paused` whenever `waiting` is requested. Note: `paused` is **not** a per-job state —

rust/src/queue.rs:789

MethodsaveStacktraceArgs

(self, job_id: str, stacktrace: str, failedReason: str)

python/bullmq/scripts.py:281

( cursor: string | number, options: { MATCH?: string; COUNT?: number }, )

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

( cursor: string | number, options: { MATCH?: string; COUNT?: number }, )

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

MethodscanStream

(options: { match: string; count?: number })

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

MethodscanStream

(options: { match: string; count?: number })

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

MethodscanStream

(options: { match: string; count?: number })

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

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

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

(...args: any[])

src/interfaces/redis-options.ts:43

(msg: any, cb?: (err: Error | null) => void)

tests/child_stdio_null.test.ts:51

tests/bun-redis-nested-duplicate.test.ts:29

tests/bun-redis.test.ts:151

MethodsendCommand

(...args: any[])

src/interfaces/redis-options.ts:42

Methodserialize

(&self, _serializer: S)

rust/src/flow_producer.rs:1319

Methodserialize

(&self, serializer: S)

rust/src/types.rs:119

Functionserializes_non_finite_numbers_as_null

rust/src/queue.rs:3026

Functionserializes_regular_values_as_json

rust/src/queue.rs:3034

( key: string, value: string | number, options?: { PX?: number; EX?: number }, )

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

( key: string, value: string | number, options?: { PX?: number; EX?: number }, )

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

( key: string, value: string | number, options?: { PX?: number; EX?: number }, )

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

MethodsetAttribute

* setAttribute sets an attribute on the span. * * @param key - attribute key * @param value - attribute value

src/interfaces/telemetry.ts:222

MethodsetAttribute

(key: string, value: any)

tests/telemetry_interface.test.ts:184

MethodsetAttributes

(attributes: Attributes)

tests/telemetry_interface.test.ts:188

Set a human-readable name on the underlying connection (observability).

python/bullmq/backend.py:62

(self, name: str)

python/bullmq/backends/redis_backend.py:121

(self, name: str)

python/bullmq/backends/postgres_backend.py:251

* Sets a human-readable name on the underlying connection (CLIENT SETNAME). * Unsupported-command and shutdown errors are swallowed.

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

MethodsetQueueMeta

(values: Record<string, string | number>)

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

MethodsetQueueMeta

(values: Record<string, string | number>)

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

MethodsetRateLimit

(expireTimeMs: number)

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

MethodsetRateLimit

(expireTimeMs: number)

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

MethodsetSpanOnContext

(ctx: any, omitContext?: boolean)

tests/telemetry_interface.test.ts:177

python/tests/queue_test.py:22

python/tests/bulk_test.py:20

python/tests/job_scheduler_test.py:24

python/tests/deduplication_test.py:20

python/tests/flow_test.py:22

python/tests/job_test.py:19

python/tests/global_rate_limit_concurrency_test.py:19

python/tests/global_rate_limit_concurrency_test.py:47

python/tests/delay_test.py:21

python/tests/lock_manager_test.py:29

python/tests/job_cancellation_test.py:71

← previous next →2,801–2,900 of 3,768, ranked by callers