diff --git a/src/server/cron/TaskRunner.js b/src/server/cron/TaskRunner.js index 7bb9a84d..56bbd084 100644 --- a/src/server/cron/TaskRunner.js +++ b/src/server/cron/TaskRunner.js @@ -65,6 +65,7 @@ class TaskRunner { const nextTry = moment().add(1, 'hours') logger.info('task lock timeout,probably other worker is doing it, retrying later', { taskName, nextTry }) taskJob.setTime(new CronTime(nextTry)) + taskJob.start() return } logger.error('Cron task failed', errMessage, exception, { taskName })