Class JobPro<DataType, ReturnType, NameType>

constructor

• new JobPro<DataType = any, ReturnType = any, NameType extends string = string>(
      queue: MinimalQueue,
      name: NameType,
      data: DataType,
      opts?: JobsProOptions,
      id?: string,
  ): JobPro<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: JobsProOptions = {}

    The options object for this job.
  • Optionalid: string

  Returns JobPro<DataType, ReturnType, NameType>

gid

asJSONSandbox

• asJSONSandbox(): JobProJsonSandbox

  Prepares a job to be passed to Sandbox.

  Returns JobProJsonSandbox

moveToCompleted

• moveToCompleted(
      returnValue: ReturnType,
      token: string,
      fetchNext?: boolean,
  ): Promise<[] | JobData>

  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<[] | JobData>

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

moveToDelayed

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

  Moves the job to the delay set.

  Parameters

  • timestamp: number

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

    token to check job is locked by current worker

  Returns Promise<void>

moveToFailed

• moveToFailed(err: Error, token: string, fetchNext?: boolean): 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: 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

remove

• remove(): 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.

  Returns Promise<void>

StaticfromJSON

• fromJSON<T = any, R = any, N extends string = string>(
      queue: MinimalQueue,
      json: JobProJsonRaw,
      jobId?: string,
  ): JobPro<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: JobProJsonRaw

    the plain object containing the job.
  • OptionaljobId: string

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

  Returns JobPro<T, R, N>