Skip to content

Commit ff274ba

Browse files
committed
fix: allow passing forkMode to every
1 parent 7dbc668 commit ff274ba

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

src/index.ts

+8-5
Original file line numberDiff line numberDiff line change
@@ -387,31 +387,31 @@ export class Agenda extends EventEmitter {
387387
interval: string | number,
388388
names: string[],
389389
data?: undefined,
390-
options?: { timezone?: string; skipImmediate?: boolean }
390+
options?: { timezone?: string; skipImmediate?: boolean; forkMode?: boolean }
391391
): Promise<Job<void>[]>;
392392
async every(
393393
interval: string | number,
394394
name: string,
395395
data?: undefined,
396-
options?: { timezone?: string; skipImmediate?: boolean }
396+
options?: { timezone?: string; skipImmediate?: boolean; forkMode?: boolean }
397397
): Promise<Job<void>>;
398398
async every<DATA = unknown>(
399399
interval: string | number,
400400
names: string[],
401401
data: DATA,
402-
options?: { timezone?: string; skipImmediate?: boolean }
402+
options?: { timezone?: string; skipImmediate?: boolean; forkMode?: boolean }
403403
): Promise<Job<DATA>[]>;
404404
async every<DATA = unknown>(
405405
interval: string | number,
406406
name: string,
407407
data: DATA,
408-
options?: { timezone?: string; skipImmediate?: boolean }
408+
options?: { timezone?: string; skipImmediate?: boolean; forkMode?: boolean }
409409
): Promise<Job<DATA>>;
410410
async every(
411411
interval: string | number,
412412
names: string | string[],
413413
data?: unknown,
414-
options?: { timezone?: string; skipImmediate?: boolean }
414+
options?: { timezone?: string; skipImmediate?: boolean; forkMode?: boolean }
415415
): Promise<Job<any> | Job<any>[]> {
416416
/**
417417
* Internal method to setup job that gets run every interval
@@ -427,6 +427,9 @@ export class Agenda extends EventEmitter {
427427
const job = this.create(name, data);
428428
job.attrs.type = 'single';
429429
job.repeatEvery(interval, options);
430+
if (options?.forkMode) {
431+
job.forkMode(options.forkMode)
432+
}
430433
await job.save();
431434

432435
return job;

0 commit comments

Comments
 (0)