diff --git a/src/classes/child-processor.ts b/src/classes/child-processor.ts index dd61dd09d9..98ea85b0e5 100644 --- a/src/classes/child-processor.ts +++ b/src/classes/child-processor.ts @@ -1,5 +1,6 @@ import { ParentCommand } from '../enums'; -import { JobJson, SandboxedJob } from '../interfaces'; +import { SandboxedJob } from '../interfaces'; +import { JobJsonSandbox } from '../types'; import { errorToJSON } from '../utils'; enum ChildStatus { @@ -61,7 +62,7 @@ export class ChildProcessor { }); } - public async start(jobJson: JobJson, token?: string): Promise { + public async start(jobJson: JobJsonSandbox, token?: string): Promise { if (this.status !== ChildStatus.Idle) { return this.send({ cmd: ParentCommand.Error, @@ -110,7 +111,7 @@ export class ChildProcessor { * The wrapped job adds back some of those original functions. */ protected wrapJob( - job: JobJson, + job: JobJsonSandbox, send: (msg: any) => Promise, ): SandboxedJob { return { diff --git a/src/classes/job.ts b/src/classes/job.ts index b10bf70084..48f1d22564 100644 --- a/src/classes/job.ts +++ b/src/classes/job.ts @@ -8,7 +8,6 @@ import { JobJson, JobJsonRaw, MinimalJob, - MoveToDelayedOpts, MoveToWaitingChildrenOpts, ParentKeys, ParentOpts, diff --git a/src/interfaces/sandboxed-job.ts b/src/interfaces/sandboxed-job.ts index aff04e98b9..c918854d6a 100644 --- a/src/interfaces/sandboxed-job.ts +++ b/src/interfaces/sandboxed-job.ts @@ -1,11 +1,10 @@ -import { JobsOptions } from '../types'; -import { JobJson } from './job-json'; +import { JobJsonSandbox, JobsOptions } from '../types'; /** * @see {@link https://docs.bullmq.io/guide/workers/sandboxed-processors} */ export interface SandboxedJob - extends Omit { + extends Omit { data: T; opts: JobsOptions; moveToDelayed: (timestamp: number, token?: string) => Promise;