diff --git a/Server/service/jobQueue.js b/Server/service/jobQueue.js index 92b7b6aab..3fdb91710 100644 --- a/Server/service/jobQueue.js +++ b/Server/service/jobQueue.js @@ -210,6 +210,9 @@ class JobQueue { */ async addJob(jobName, payload) { try { + // Execute job immediately + await this.queue.add(jobName, payload); + await this.queue.add(jobName, payload, { repeat: { every: payload.interval,