diff --git a/apps/worker/src/app/workflow/services/completed-jobs-metric.service.ts b/apps/worker/src/app/workflow/services/completed-jobs-metric.service.ts index 137668cdd22..f08ae154985 100644 --- a/apps/worker/src/app/workflow/services/completed-jobs-metric.service.ts +++ b/apps/worker/src/app/workflow/services/completed-jobs-metric.service.ts @@ -28,7 +28,7 @@ export class CompletedJobsMetricService { this.completedJobsMetricWorkerService.createWorker(this.getWorkerProcessor(), this.getWorkerOptions()); this.completedJobsMetricWorkerService.worker.on('completed', async (job) => { - await checkingForCronJob(process.env.ACTIVE_CRON_ID); + await checkingForCronJob(process.env.COMPLETED_CRON_ID); Logger.verbose('Metric Completed Job', job.id, LOG_CONTEXT); });