Class JobPro<DataType, ReturnType, NameType>

constructor

• JobPro(queue, name, data, opts?, id?): JobPro<DataType, ReturnType, NameType>

• Parameters

  • queue: MinimalQueue
  • name: NameType

    The name of the Job
  • data: DataType

    The payload for this job.
  • opts: JobsProOptions = {}

    The options object for this job.
  • Optional id: string

  Returns JobPro<DataType, ReturnType, NameType>

gid

opts

asJSONSandbox

• asJSONSandbox(): JobProJsonSandbox

• Prepares a job to be passed to Sandbox.

  Returns JobProJsonSandbox

extendLock

• extendLock(token, duration): 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>

getBatch

• getBatch(): JobPro<any, any, string>[]

• Returns the batch of jobs for this job if any.

  Returns JobPro<any, any, string>[]

  See

  • Job
  • bullmq!JobPro | JobPro

  Example

  
  
  Copy

moveToCompleted

• moveToCompleted(returnValue, token, fetchNext?): Promise<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<any[]>

  Returns the jobData of the next job in the waiting queue.

moveToDelayed

• moveToDelayed(timestamp, token?): Promise<void>

• Moves the job to the delay set.

  Parameters

  • timestamp: number

    timestamp where the job should be moved back to "wait"
  • Optional token: string

    token to check job is locked by current worker

  Returns Promise<void>

moveToFailed

• moveToFailed(err, token, fetchNext?): Promise<void>

• Moves a job to the failed queue.

  Parameters

  • err: Error

    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>

  void

moveToWaitingChildren

• moveToWaitingChildren(token, opts?): 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

setAsFailed

• setAsFailed(err): void

• Set job as failed. This method will set the current job instance as failed, it is useful when processing batches to mark a certain job in a batch as failed while completing the rest.

  Parameters

  • err: Error

    The error object to be associated with the job.

  Returns void

setBatch

• setBatch(jobs): void

• Sets a batch of jobs for this job.

  Parameters

  • jobs: JobPro<any, any, string>[]

  Returns void

Static fromJob

• fromJob(queue, job): JobPro<DataType, ResultType, NameType>

• Instantiates a JobPro instance based on a standard Job instance.

  Parameters

  • queue: MinimalQueue
  • job: Job

  Returns JobPro<DataType, ResultType, NameType>

Static fromJSON

• fromJSON(queue, json, jobId?): JobPro<T, R, N>

• Instantiates a Job from a JobJsonRaw object (coming from a deserialized JSON object)

  Parameters

  • queue: MinimalQueue

    the queue where the job belongs to.
  • json: JobProJsonRaw

    the plain object containing the job.
  • Optional jobId: string

    an optional job id (overrides the id coming from the JSON object)

  Returns JobPro<T, R, N>