Class JobWorker

constructor

• new JobWorker(
      repository: JobRepository,
      namespace: string,
      options: JobWorkerOptions,
  ): JobWorker

  Parameters

  • repository: JobRepository
  • namespace: string
  • options: JobWorkerOptions

  Returns JobWorker

lastError

start

• start(): Promise<void>

  Start polling; resolves after startup, not after jobs finish. A worker is single-use.

  Returns Promise<void>

stop

• stop(options?: { drainTimeoutMs?: number }): Promise<void>

  Stop claims, drain, then abort. Does not forcibly stop an ordinary function.

  Parameters

  • options: { drainTimeoutMs?: number } = {}

  Returns Promise<void>