Class Job<DataType, ReturnType, NameType>

Job

This class represents a Job in the queue. Normally job are implicitly created when you add a job to the queue with methods such as Queue.addJob( ... )

A Job instance is also passed to the Worker's process function.

Type Parameters

DataType = any
ReturnType = any
NameType extends string = string

Implements

MinimalJob<DataType, ReturnType, NameType>

Index

Constructors

constructor

Accessors

prefix queueName

Constructors

constructor

new Job<DataType = any, ReturnType = any, NameType extends string = string>(
    queue: MinimalQueue,
    name: NameType,
    data: DataType,
    opts?: JobsOptions,
    id?: string,
): Job<DataType, ReturnType, NameType>
Type Parameters
- DataType = any
- ReturnType = any
- NameType extends string = string
Parameters
- queue: MinimalQueue
- name: NameType
  The name of the Job
- data: DataType
  The payload for this job.
- opts: JobsOptions = {}
  The options object for this job.
- Optionalid: string
Returns Job<DataType, ReturnType, NameType>
- Defined in classes/job.ts:195

Properties

attemptsMade

attemptsMade: number = 0

Number of attempts after the job has failed.

Default Value

attemptsStarted

attemptsStarted: number = 0

Number of attempts when job is moved to active.

Default Value

data

data: DataType

The payload for this job.

`Optional`debounceId

debounceId?: string

Debounce identifier.

Deprecated

use deduplicationId

`Optional`deduplicationId

deduplicationId?: string

Deduplication identifier.

deferredFailure

deferredFailure: string

Deferred failure. Stores a failed message and marks this job to be failed directly as soon as the job is picked up by a worker, and using this string as the failed reason.

delay

delay: number = 0

An amount of milliseconds to wait until this job can be processed.

Default Value

failedReason

failedReason: string

Reason for failing.

`Optional`finishedOn

finishedOn?: number

Timestamp for when the job finished (completed or failed).

`Optional`id

id?: string

name

name: NameType

The name of the Job

`Optional`nextRepeatableJobId

nextRepeatableJobId?: string

Produced next repetable job Id.

opts

opts: JobsOptions = {}

The options object for this job.

`Optional`parent

parent?: ParentKeys

Object that contains parentId (id) and parent queueKey.

`Optional`parentKey

parentKey?: string

Fully qualified key (including the queue prefix) pointing to the parent of this job.

priority

priority: number = 0

Ranges from 0 (highest priority) to 2 097 152 (lowest priority). Note that using priorities has a slight impact on performance, so do not use it if not required.

Default Value

`Optional`processedBy

processedBy?: string

The worker name that is processing or processed this job.

`Optional`processedOn

processedOn?: number

Timestamp for when the job was processed.

progress

progress: JobProgress = 0

The progress a job has performed so far.

Default Value

`Readonly`queueQualifiedName

queueQualifiedName: string

It includes the prefix, the namespace separator :, and queue name.

See

https://www.gnu.org/software/gawk/manual/html_node/Qualified-Names.html

`Optional`repeatJobKey

repeatJobKey?: string

Base repeat job key.

returnvalue

returnvalue: ReturnType = null

The value returned by the processor when processing this job.

Default Value

null

stacktrace

stacktrace: string[] = null

Stacktrace for the error (for failed jobs).

Default Value

null

stalledCounter

stalledCounter: number = 0

Number of times where job has stalled.

Default Value

timestamp

timestamp: number

Timestamp when the job was created (unless overridden with job options).

`Optional`token

token?: string

The token used for locking this job.

Accessors

prefix

get prefix(): string
Returns string
the prefix that is used.
Implementation of MinimalJob.prefix
- Defined in classes/job.ts:941

queueName

get queueName(): string
Returns string
the queue name this job belongs to.
Implementation of MinimalJob.queueName
- Defined in classes/job.ts:934

Methods

addJob

addJob(client: RedisClient, parentOpts?: ParentKeyOpts): Promise<string>
Adds the job to Redis.
Parameters
- client: RedisClient
- OptionalparentOpts: ParentKeyOpts
Returns Promise<string>
- Defined in classes/job.ts:1416

asJSON

asJSON(): JobJson
Prepares a job to be serialized for storage in Redis.

Returns JobJson
Implementation of MinimalJob.asJSON
- Defined in classes/job.ts:517

asJSONSandbox

asJSONSandbox(): JobJsonSandbox
Prepares a job to be passed to Sandbox.

Returns JobJsonSandbox
Implementation of MinimalJob.asJSONSandbox
- Defined in classes/job.ts:580

changeDelay

changeDelay(delay: number): Promise<void>
Change delay of a delayed job.
Parameters
- delay: number
  milliseconds to be added to current time.
Returns Promise<void>
void
- Defined in classes/job.ts:961

changePriority

changePriority(opts: { lifo?: boolean; priority?: number }): Promise<void>
Change job priority.
Parameters
- opts: { lifo?: boolean; priority?: number }
  options containing priority and lifo values.
Returns Promise<void>
void
- Defined in classes/job.ts:972

clearLogs

clearLogs(keepLogs?: number): Promise<void>
Clears job's logs
Parameters
- OptionalkeepLogs: number
  the amount of log entries to preserve
Returns Promise<void>
- Defined in classes/job.ts:644

discard

discard(): void
Marks a job to not be retried if it fails (even if attempts has been configured)

Returns void
Deprecated
use UnrecoverableError
- Defined in classes/job.ts:1394

extendLock

extendLock(token: string, duration: number): Promise<number>
Extend the lock for this job.
Parameters
- token: string
  unique token for the lock
- duration: number
  lock duration in milliseconds
Returns Promise<number>
- Defined in classes/job.ts:697

getChildrenValues

getChildrenValues<CT = any>(): Promise<{ [jobKey: string]: CT }>
Get this jobs children result values if any.
Type Parameters
- CT = any
Returns Promise<{ [jobKey: string]: CT }>
Object mapping children job keys with their values.
- Defined in classes/job.ts:985

getDependencies

getDependencies(
    opts?: DependenciesOpts,
): Promise<
    {
        failed?: string[];
        ignored?: Record<string, any>;
        nextFailedCursor?: number;
        nextIgnoredCursor?: number;
        nextProcessedCursor?: number;
        nextUnprocessedCursor?: number;
        processed?: Record<string, any>;
        unprocessed?: string[];
    },
>
Get children job keys if this job is a parent and has children.
Parameters
- opts: DependenciesOpts = {}
Returns Promise<
    {
        failed?: string[];
        ignored?: Record<string, any>;
        nextFailedCursor?: number;
        nextIgnoredCursor?: number;
        nextProcessedCursor?: number;
        nextUnprocessedCursor?: number;
        processed?: Record<string, any>;
        unprocessed?: string[];
    },
>
dependencies separated by processed, unprocessed, ignored and failed.
Remarks
Count options before Redis v7.2 works as expected with any quantity of entries on processed/unprocessed dependencies, since v7.2 you must consider that count won't have any effect until processed/unprocessed dependencies have a length greater than 127
See
- https://redis.io/docs/management/optimization/memory-optimization/#redis--72
- https://docs.bullmq.io/guide/flows#getters
- Defined in classes/job.ts:1034

getDependenciesCount

getDependenciesCount(
    opts?: {
        failed?: boolean;
        ignored?: boolean;
        processed?: boolean;
        unprocessed?: boolean;
    },
): Promise<
    {
        failed?: number;
        ignored?: number;
        processed?: number;
        unprocessed?: number;
    },
>
Get children job counts if this job is a parent and has children.
Parameters
- opts: {
      failed?: boolean;
      ignored?: boolean;
      processed?: boolean;
      unprocessed?: boolean;
  } = {}
Returns Promise<
    {
        failed?: number;
        ignored?: number;
        processed?: number;
        unprocessed?: number;
    },
>
dependencies count separated by processed, unprocessed, ignored and failed.
- Defined in classes/job.ts:1211

getFailedChildrenValues

getFailedChildrenValues(): Promise<{ [jobKey: string]: string }>
Get job's children failure values that were ignored if any.

Returns Promise<{ [jobKey: string]: string }>
Object mapping children job keys with their failure values.

Deprecated
This method is deprecated and will be removed in v6. Use getIgnoredChildrenFailures instead.
- Defined in classes/job.ts:1017

getIgnoredChildrenFailures

getIgnoredChildrenFailures(): Promise<{ [jobKey: string]: string }>
Retrieves the failures of child jobs that were explicitly ignored while using ignoreDependencyOnFailure option. This method is useful for inspecting which child jobs were intentionally ignored when an error occured.

Returns Promise<{ [jobKey: string]: string }>
Object mapping children job keys with their failure values.

See
https://docs.bullmq.io/guide/flows/ignore-dependency
- Defined in classes/job.ts:1004

getState

getState(): Promise<"unknown" | JobState>
Get current state.

Returns Promise<"unknown" | JobState>
Returns one of these values: 'completed', 'failed', 'delayed', 'active', 'waiting', 'waiting-children', 'unknown'.
- Defined in classes/job.ts:951

isActive

isActive(): Promise<boolean>
Returns Promise<boolean>
true of the job is active.
- Defined in classes/job.ts:920

isCompleted

isCompleted(): Promise<boolean>
Returns Promise<boolean>
true if the job has completed.
- Defined in classes/job.ts:892

isDelayed

isDelayed(): Promise<boolean>
Returns Promise<boolean>
true if the job is delayed.
- Defined in classes/job.ts:906

isFailed

isFailed(): Promise<boolean>
Returns Promise<boolean>
true if the job has failed.
- Defined in classes/job.ts:899

isWaiting

isWaiting(): Promise<boolean>
Returns Promise<boolean>
true if the job is waiting.
- Defined in classes/job.ts:927

isWaitingChildren

isWaitingChildren(): Promise<boolean>
Returns Promise<boolean>
true if the job is waiting for children.
- Defined in classes/job.ts:913

log

log(logRow: string): Promise<number>
Logs one row of log data.
Parameters
- logRow: string
  string with log data to be logged.
Returns Promise<number>
The total number of log entries for this job so far.
Implementation of MinimalJob.log
- Defined in classes/job.ts:616

moveToCompleted

moveToCompleted(
    returnValue: ReturnType,
    token: string,
    fetchNext?: boolean,
): Promise<void | any[]>
Moves a job to the completed queue. Returned job to be used with Queue.prototype.nextJobFromJobData.
Parameters
- returnValue: ReturnType
  The jobs success message.
- token: string
  Worker token used to acquire completed job.
- fetchNext: boolean = true
  True when wanting to fetch the next job.
Returns Promise<void | any[]>
Returns the jobData of the next job in the waiting queue or void.
- Defined in classes/job.ts:710

moveToDelayed

moveToDelayed(timestamp: number, token?: string): Promise<void>
Moves the job to the delay set.
Parameters
- timestamp: number
  timestamp when the job should be moved back to "wait"
- Optionaltoken: string
  token to check job is locked by current worker
Returns Promise<void>
- Defined in classes/job.ts:1326

moveToFailed

moveToFailed<E extends Error>(
    err: E,
    token: string,
    fetchNext?: boolean,
): Promise<void | any[]>
Moves a job to the failed queue.
Type Parameters
- E extends Error
Parameters
- err: E
  the jobs error message.
- token: string
  token to check job is locked by current worker
- fetchNext: boolean = false
  true when wanting to fetch the next job
Returns Promise<void | any[]>
Returns the jobData of the next job in the waiting queue or void.
- Defined in classes/job.ts:795

moveToWait

moveToWait(token?: string): Promise<number>
Moves a job to the wait or prioritized state.
Parameters
- Optionaltoken: string
  Worker token used to acquire completed job.
Returns Promise<number>
Returns pttl.
- Defined in classes/job.ts:761

moveToWaitingChildren

moveToWaitingChildren(
token: string,
opts?: MoveToWaitingChildrenOpts,
): Promise<boolean>
Moves the job to the waiting-children set.
Parameters
- token: string
  Token to check job is locked by current worker
- opts: MoveToWaitingChildrenOpts = {}
  The options bag for moving a job to waiting-children.
Returns Promise<boolean>
true if the job was moved
- Defined in classes/job.ts:1349

promote

promote(): Promise<void>
Promotes a delayed job so that it starts to be processed as soon as possible.

Returns Promise<void>
- Defined in classes/job.ts:1365

remove

remove(opts?: { removeChildren?: boolean }): Promise<void>
Completely remove the job from the queue. Note, this call will throw an exception if the job is being processed when the call is performed.
Parameters
- opts: { removeChildren?: boolean } = {}
  Options to remove a job
Returns Promise<void>
- Defined in classes/job.ts:662

removeChildDependency

removeChildDependency(): Promise<boolean>
Removes child dependency from parent when child is not yet finished

Returns Promise<boolean>
True if the relationship existed and if it was removed.
- Defined in classes/job.ts:625

removeUnprocessedChildren

removeUnprocessedChildren(): Promise<void>
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.

Returns Promise<void>
Remarks
- Jobs with locks (most likely active) are ignored.
- This method can be slow if the number of children is large (> 1000).
- Defined in classes/job.ts:686

retry

retry(state?: FinishedStatus): Promise<void>
Attempts to retry the job. Only a job that has failed or completed can be retried.
Parameters
- state: FinishedStatus = 'failed'
  completed / failed
Returns Promise<void>
If resolved and return code is 1, then the queue emits a waiting event otherwise the operation was not a success and throw the corresponding error. If the promise rejects, it indicates that the script failed to execute
- Defined in classes/job.ts:1381

toJSON

toJSON(): Omit<
    Job<DataType, ReturnType, NameType>,

        | "remove"
        | "prefix"
        | "toJSON"
        | "scripts"
        | "addJob"
        | "removeUnprocessedChildren"
        | "extendLock"
        | "updateData"
        | "updateProgress"
        | "removeChildDependency"
        | "getState"
        | "changeDelay"
        | "changePriority"
        | "moveToDelayed"
        | "moveToWaitingChildren"
        | "promote"
        | "discard"
        | "queue"
        | "asJSON"
        | "asJSONSandbox"
        | "log"
        | "clearLogs"
        | "moveToCompleted"
        | "moveToWait"
        | "moveToFailed"
        | "isCompleted"
        | "isFailed"
        | "isDelayed"
        | "isWaitingChildren"
        | "isActive"
        | "isWaiting"
        | "queueName"
        | "getChildrenValues"
        | "getIgnoredChildrenFailures"
        | "getFailedChildrenValues"
        | "getDependencies"
        | "getDependenciesCount"
        | "waitUntilFinished"
        | "retry",
>
Returns Omit<
    Job<DataType, ReturnType, NameType>,

        | "remove"
        | "prefix"
        | "toJSON"
        | "scripts"
        | "addJob"
        | "removeUnprocessedChildren"
        | "extendLock"
        | "updateData"
        | "updateProgress"
        | "removeChildDependency"
        | "getState"
        | "changeDelay"
        | "changePriority"
        | "moveToDelayed"
        | "moveToWaitingChildren"
        | "promote"
        | "discard"
        | "queue"
        | "asJSON"
        | "asJSONSandbox"
        | "log"
        | "clearLogs"
        | "moveToCompleted"
        | "moveToWait"
        | "moveToFailed"
        | "isCompleted"
        | "isFailed"
        | "isDelayed"
        | "isWaitingChildren"
        | "isActive"
        | "isWaiting"
        | "queueName"
        | "getChildrenValues"
        | "getIgnoredChildrenFailures"
        | "getFailedChildrenValues"
        | "getDependencies"
        | "getDependenciesCount"
        | "waitUntilFinished"
        | "retry",
>
- Defined in classes/job.ts:508

updateData

updateData(data: DataType): Promise<void>
Updates a job's data
Parameters
- data: DataType
  the data that will replace the current jobs data.
Returns Promise<void>
Implementation of MinimalJob.updateData
- Defined in classes/job.ts:593

updateProgress

updateProgress(progress: JobProgress): Promise<void>
Updates a job's progress
Parameters
- progress: JobProgress
  number or object to be saved as progress.
Returns Promise<void>
Implementation of MinimalJob.updateProgress
- Defined in classes/job.ts:604

waitUntilFinished

waitUntilFinished(queueEvents: QueueEvents, ttl?: number): Promise<ReturnType>
Returns a promise the resolves when the job has completed (containing the return value of the job), or rejects when the job has failed (containing the failedReason).
Parameters
- queueEvents: QueueEvents
  Instance of QueueEvents.
- Optionalttl: number
  Time in milliseconds to wait for job to finish before timing out.
Returns Promise<ReturnType>
- Defined in classes/job.ts:1254

`Static`addJobLog

addJobLog(
    queue: MinimalQueue,
    jobId: string,
    logRow: string,
    keepLogs?: number,
): Promise<number>
addJobLog
Parameters
- queue: MinimalQueue
  A minimal queue instance
- jobId: string
  Job id
- logRow: string
  String with a row of log data to be logged
- OptionalkeepLogs: number
  The optional amount of log entries to preserve
Returns Promise<number>
The total number of log entries for this job so far.
- Defined in classes/job.ts:497

`Static`create

create<T = any, R = any, N extends string = string>(
    queue: MinimalQueue,
    name: N,
    data: T,
    opts?: JobsOptions,
): Promise<Job<T, R, N>>
Creates a new job and adds it to the queue.
Type Parameters
- T = any
- R = any
- N extends string = string
Parameters
- queue: MinimalQueue
  the queue where to add the job.
- name: N
  the name of the job.
- data: T
  the payload of the job.
- Optionalopts: JobsOptions
  the options bag for this job.
Returns Promise<Job<T, R, N>>
- Defined in classes/job.ts:274

`Static`createBulk

createBulk<T = any, R = any, N extends string = string>(
queue: MinimalQueue,
jobs: { data: T; name: N; opts?: BulkJobOptions }[],
): Promise<Job<T, R, N>[]>
Creates a bulk of jobs and adds them atomically to the given queue.
Type Parameters
- T = any
- R = any
- N extends string = string
Parameters
- queue: MinimalQueue
  the queue were to add the jobs.
- jobs: { data: T; name: N; opts?: BulkJobOptions }[]
  an array of jobs to be added to the queue.
Returns Promise<Job<T, R, N>[]>
- Defined in classes/job.ts:301

`Static`fromId

fromId<T = any, R = any, N extends string = string>(
queue: MinimalQueue,
jobId: string,
): Promise<Job<T, R, N>>
Fetches a Job from the queue given the passed job id.
Type Parameters
- T = any
- R = any
- N extends string = string
Parameters
- queue: MinimalQueue
  the queue where the job belongs to.
- jobId: string
  the job id.
Returns Promise<Job<T, R, N>>
- Defined in classes/job.ts:469

`Static`fromJSON

fromJSON<T = any, R = any, N extends string = string>(
    queue: MinimalQueue,
    json: JobJsonRaw,
    jobId?: string,
): Job<T, R, N>
Instantiates a Job from a JobJsonRaw object (coming from a deserialized JSON object)
Type Parameters
- T = any
- R = any
- N extends string = string
Parameters
- queue: MinimalQueue
  the queue where the job belongs to.
- json: JobJsonRaw
  the plain object containing the job.
- OptionaljobId: string
  an optional job id (overrides the id coming from the JSON object)
Returns Job<T, R, N>
- Defined in classes/job.ts:348

`Static`optsAsJSON

optsAsJSON(
opts?: JobsOptions,
optsEncode?: Record<string, string>,
): RedisJobOptions
Parameters
- opts: JobsOptions = {}
- optsEncode: Record<string, string> = optsEncodeMap
Returns RedisJobOptions
- Defined in classes/job.ts:542

`Static`optsFromJSON

optsFromJSON(rawOpts?: string, optsDecode?: Record<string, string>): JobsOptions
Parameters
- OptionalrawOpts: string
- optsDecode: Record<string, string> = optsDecodeMap
Returns JobsOptions
- Defined in classes/job.ts:432

Class Job<DataType, ReturnType, NameType>

Type Parameters

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

Parameters

Returns Job<DataType, ReturnType, NameType>

Properties

attemptsMade

Default Value

attemptsStarted

Default Value

data

OptionaldebounceId

Deprecated

OptionaldeduplicationId

deferredFailure

delay

Default Value

failedReason

OptionalfinishedOn

Optionalid

name

OptionalnextRepeatableJobId

opts

Optionalparent

OptionalparentKey

priority

Default Value

OptionalprocessedBy

OptionalprocessedOn

progress

Default Value

ReadonlyqueueQualifiedName

See

OptionalrepeatJobKey

returnvalue

Default Value

stacktrace

Default Value

stalledCounter

Default Value

timestamp

Optionaltoken

Accessors

prefix

Returns string

queueName

Returns string

Methods

addJob

Parameters

Returns Promise<string>

asJSON

Returns JobJson

asJSONSandbox

Returns JobJsonSandbox

changeDelay

Parameters

Returns Promise<void>

changePriority

Parameters

Returns Promise<void>

clearLogs

Parameters

Returns Promise<void>

discard

Returns void

Deprecated

extendLock

Parameters

Returns Promise<number>

getChildrenValues

Type Parameters

`Optional`debounceId

`Optional`deduplicationId

`Optional`finishedOn

`Optional`id

`Optional`nextRepeatableJobId

`Optional`parent

`Optional`parentKey

`Optional`processedBy

`Optional`processedOn

`Readonly`queueQualifiedName

`Optional`repeatJobKey

`Optional`token

Returns Promise<
{
failed?: string[];
ignored?: Record<string, any>;
nextFailedCursor?: number;
nextIgnoredCursor?: number;
nextProcessedCursor?: number;
nextUnprocessedCursor?: number;
processed?: Record<string, any>;
unprocessed?: string[];
},
>

Returns Promise<
{
failed?: number;
ignored?: number;
processed?: number;
unprocessed?: number;
},
>