diff --git a/apps/cron/src/tasks/check.missing.queues.ts b/apps/cron/src/tasks/check.missing.queues.ts index 6c9def7f..0664676c 100644 --- a/apps/cron/src/tasks/check.missing.queues.ts +++ b/apps/cron/src/tasks/check.missing.queues.ts @@ -28,6 +28,7 @@ export class CheckMissingQueues { ) ).filter((p) => !p.isJob); + for (const job of notExists) { this._workerServiceProducer.emit('post', { id: job.id,