From b0af87a6b19048dd5c07faadcc0222ba56224abc Mon Sep 17 00:00:00 2001 From: William Oldham Date: Sat, 4 Nov 2023 11:34:45 +0000 Subject: [PATCH] Add logger to job helper --- src/modules/jobs/job.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/modules/jobs/job.ts b/src/modules/jobs/job.ts index 30c7b5b..fbe1550 100644 --- a/src/modules/jobs/job.ts +++ b/src/modules/jobs/job.ts @@ -2,6 +2,7 @@ import { getORM } from '@/modules/mikro'; import { scopedLogger } from '@/services/logger'; import { EntityManager } from '@mikro-orm/postgresql'; import { CronJob } from 'cron'; +import { Logger } from 'winston'; const minOffset = 0; const maxOffset = 60 * 4; @@ -20,7 +21,7 @@ const wait = (sec: number) => */ export function job( cron: string, - cb: (ctx: { em: EntityManager }) => Promise, + cb: (ctx: { em: EntityManager; log: Logger }) => Promise, ): CronJob { return CronJob.from({ cronTime: cron, @@ -32,7 +33,7 @@ export function job( // actually run the job try { const em = getORM().em.fork(); - await cb({ em }); + await cb({ em, log }); } catch (err) { log.error('Failed to run job!'); log.error(err);