diff --git a/backend/src/services/task-scheduler.service.ts b/backend/src/services/task-scheduler.service.ts index b66bf40..4fccb97 100644 --- a/backend/src/services/task-scheduler.service.ts +++ b/backend/src/services/task-scheduler.service.ts @@ -137,7 +137,7 @@ export class TaskSchedulerService { } } - protected scheduleTask(task: IScheduledTask): void { + protected async scheduleTask(task: IScheduledTask): Promise { const { name, type, scheduleOrDelay, callback } = task; if (this.scheduledTasks.has(name)) { @@ -167,6 +167,8 @@ export class TaskSchedulerService { this.logger.error(`Error running cron task "${name}":`, error); } }); + // Start the job immediately + await callback(); job.start(); this.scheduledTasks.set(name, job); } else if (type === 'timeout') {