Class Scripts

constructor

• new Scripts(queue: MinimalQueue): Scripts

  Parameters

  • queue: MinimalQueue

  Returns Scripts

moveToFinishedKeys

addJob

• addJob(
      client: RedisClient,
      job: JobJson,
      opts: RedisJobOptions,
      jobId: string,
      parentOpts?: ParentOpts,
  ): Promise<string>

  Parameters

  • client: RedisClient
  • job: JobJson
  • opts: RedisJobOptions
  • jobId: string
  • parentOpts: ParentOpts = {}

  Returns Promise<string>

changeDelay

• changeDelay(jobId: string, delay: number): Promise<void>

  Parameters

  • jobId: string
  • delay: number

  Returns Promise<void>

changePriority

• changePriority(jobId: string, priority?: number, lifo?: boolean): Promise<void>

  Parameters

  • jobId: string
  • priority: number = 0
  • lifo: boolean = false

  Returns Promise<void>

cleanJobsInSet

• cleanJobsInSet(
      set: string,
      timestamp: number,
      limit?: number,
  ): Promise<string[]>

  Remove jobs in a specific state.

  Parameters

  • set: string
  • timestamp: number
  • limit: number = 0

  Returns Promise<string[]>

  Id jobs from the deleted records.

drain

• drain(delayed: boolean): Promise<void>

  Parameters

  • delayed: boolean

  Returns Promise<void>

execCommand

• execCommand(
      client: ChainableCommander | RedisClient,
      commandName: string,
      args: any[],
  ): any

  Parameters

  • client: ChainableCommander | RedisClient
  • commandName: string
  • args: any[]

  Returns any

extendLock

• extendLock(
      jobId: string,
      token: string,
      duration: number,
      client?: ChainableCommander | RedisClient,
  ): Promise<number>

  Parameters

  • jobId: string
  • token: string
  • duration: number
  • Optionalclient: ChainableCommander | RedisClient

  Returns Promise<number>

finishedErrors

• finishedErrors(
      code: number,
      jobId: string,
      command: string,
      state?: string,
  ): Error

  Parameters

  • code: number
  • jobId: string
  • command: string
  • Optionalstate: string

  Returns Error

getCounts

• getCounts(types: JobType[]): Promise<number[]>

  Parameters

  • types: JobType[]

  Returns Promise<number[]>

getRanges

• getRanges(
      types: JobType[],
      start?: number,
      end?: number,
      asc?: boolean,
  ): Promise<[string][]>

  Parameters

  • types: JobType[]
  • start: number = 0
  • end: number = 1
  • asc: boolean = false

  Returns Promise<[string][]>

getState

• getState(jobId: string): Promise<"unknown" | JobState>

  Parameters

  • jobId: string

  Returns Promise<"unknown" | JobState>

isFinished

• isFinished(
      jobId: string,
      returnValue?: boolean,
  ): Promise<number | [number, string]>

  Parameters

  • jobId: string
  • returnValue: boolean = false

  Returns Promise<number | [number, string]>

isJobInList

• isJobInList(listKey: string, jobId: string): Promise<boolean>

  Parameters

  • listKey: string
  • jobId: string

  Returns Promise<boolean>

moveJobFromActiveToWait

• moveJobFromActiveToWait(jobId: string, token: string): Promise<any>

  Moves a job back from Active to Wait. This script is used when a job has been manually rate limited and needs to be moved back to wait from active status.

  Parameters

  • jobId: string

    Job id

  • token: string

  Returns Promise<any>

moveStalledJobsToWait

• moveStalledJobsToWait(): Promise<[string[], string[]]>

  Looks for unlocked jobs in the active queue.

  The job was being worked on, but the worker process died and it failed to renew the lock. We call these jobs 'stalled'. This is the most common case. We resolve these by moving them back to wait to be re-processed. To prevent jobs from cycling endlessly between active and wait, (e.g. if the job handler keeps crashing), we limit the number stalled job recoveries to settings.maxStalledCount.

  Returns Promise<[string[], string[]]>

moveToActive

• moveToActive(token: string, jobId?: string): Promise<any[]>

  Parameters

  • token: string
  • OptionaljobId: string

  Returns Promise<any[]>

moveToCompletedArgs

• moveToCompletedArgs<T = any, R = any, N extends string = string>(
      job: MinimalJob<T, R, N>,
      returnvalue: R,
      removeOnComplete: number | boolean | KeepJobs,
      token: string,
      fetchNext?: boolean,
  ): (string | number | boolean | Buffer)[]

  Type Parameters

  • T = any
  • R = any
  • N extends string = string

  Parameters

  • job: MinimalJob<T, R, N>
  • returnvalue: R
  • removeOnComplete: number | boolean | KeepJobs
  • token: string
  • fetchNext: boolean = false

  Returns (string | number | boolean | Buffer)[]

moveToDelayed

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

  Parameters

  • jobId: string
  • timestamp: number
  • token: string = '0'

  Returns Promise<void>

moveToDelayedArgs

• moveToDelayedArgs(
      jobId: string,
      timestamp: number,
      token: string,
  ): (string | number)[]

  Parameters

  • jobId: string
  • timestamp: number
  • token: string

  Returns (string | number)[]

moveToFailedArgs

• moveToFailedArgs<T = any, R = any, N extends string = string>(
      job: MinimalJob<T, R, N>,
      failedReason: string,
      removeOnFailed: number | boolean | KeepJobs,
      token: string,
      fetchNext?: boolean,
  ): (string | number | boolean | Buffer)[]

  Type Parameters

  • T = any
  • R = any
  • N extends string = string

  Parameters

  • job: MinimalJob<T, R, N>
  • failedReason: string
  • removeOnFailed: number | boolean | KeepJobs
  • token: string
  • fetchNext: boolean = false

  Returns (string | number | boolean | Buffer)[]

moveToFinished

• moveToFinished(
      jobId: string,
      args: (string | number | boolean | Buffer)[],
  ): Promise<any[]>

  Parameters

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

  Returns Promise<any[]>

moveToWaitingChildren

• moveToWaitingChildren(
      jobId: string,
      token: string,
      opts?: MoveToWaitingChildrenOpts,
  ): Promise<boolean>

  Move parent job to waiting-children state.

  Parameters

  • jobId: string
  • token: string
  • opts: MoveToWaitingChildrenOpts = {}

  Returns Promise<boolean>

  true if job is successfully moved, false if there are pending dependencies.

  Throws

  JobNotExist This exception is thrown if jobId is missing.

  Throws

  JobLockNotExist This exception is thrown if job lock is missing.

  Throws

  JobNotInState This exception is thrown if job is not in active state.

moveToWaitingChildrenArgs

• moveToWaitingChildrenArgs(
      jobId: string,
      token: string,
      opts?: MoveToWaitingChildrenOpts,
  ): string[]

  Parameters

  • jobId: string
  • token: string
  • Optionalopts: MoveToWaitingChildrenOpts

  Returns string[]

obliterate

• obliterate(opts: { count: number; force: boolean }): Promise<number>

  Parameters

  • opts: { count: number; force: boolean }

  Returns Promise<number>

pause

• pause(pause: boolean): Promise<void>

  Parameters

  • pause: boolean

  Returns Promise<void>

promote

• promote(jobId: string): Promise<number>

  Parameters

  • jobId: string

  Returns Promise<number>

remove

• remove(jobId: string): Promise<number>

  Parameters

  • jobId: string

  Returns Promise<number>

removeRepeatable

• removeRepeatable(repeatJobId: string, repeatJobKey: string): Promise<number>

  Parameters

  • repeatJobId: string
  • repeatJobKey: string

  Returns Promise<number>

reprocessJob

• reprocessJob<T = any, R = any, N extends string = string>(
      job: MinimalJob<T, R, N>,
      state: "completed" | "failed",
  ): Promise<void>

  Attempts to reprocess a job

  Type Parameters

  • T = any
  • R = any
  • N extends string = string

  Parameters

  • job: MinimalJob<T, R, N>
  • state: "completed" | "failed"

    The expected job state. If the job is not found on the provided state, then it's not reprocessed. Supported states: 'failed', 'completed'

  Returns Promise<void>

  Returns a promise that evaluates to a return code: 1 means the operation was a success 0 means the job does not exist -1 means the job is currently locked and can't be retried. -2 means the job was not found in the expected set

retryJobArgs

• retryJobArgs(jobId: string, lifo: boolean, token: string): (string | number)[]

  Parameters

  • jobId: string
  • lifo: boolean
  • token: string

  Returns (string | number)[]

retryJobs

• retryJobs(
      state?: FinishedStatus,
      count?: number,
      timestamp?: number,
  ): Promise<number>

  Parameters

  • state: FinishedStatus = 'failed'
  • count: number = 1000
  • timestamp: number = ...

  Returns Promise<number>

saveStacktraceArgs

• saveStacktraceArgs(
      jobId: string,
      stacktrace: string,
      failedReason: string,
  ): string[]

  Parameters

  • jobId: string
  • stacktrace: string
  • failedReason: string

  Returns string[]

updateData

• updateData<T = any, R = any, N extends string = string>(
      job: MinimalJob<T, R, N>,
      data: T,
  ): Promise<void>

  Type Parameters

  • T = any
  • R = any
  • N extends string = string

  Parameters

  • job: MinimalJob<T, R, N>
  • data: T

  Returns Promise<void>

updateProgress

• updateProgress<T = any, R = any, N extends string = string>(
      job: MinimalJob<T, R, N>,
      progress: number | object,
  ): Promise<void>

  Type Parameters

  • T = any
  • R = any
  • N extends string = string

  Parameters

  • job: MinimalJob<T, R, N>
  • progress: number | object

  Returns Promise<void>