Merge pull request #331 from automatisch/fix/graceful-shutdown-worker

fix: Implement graceful shutdown for worker and queue scheduler

packages/backend/src/queues/processor.ts

@@ -10,7 +10,11 @@ const redisConnection = {
 };
 
 const processorQueue = new Queue('processor', redisConnection);
-new QueueScheduler('processor', redisConnection);
+const queueScheduler = new QueueScheduler('processor', redisConnection);
+
+process.on('SIGTERM', async () => {
+  await queueScheduler.close();
+});
 
 processorQueue.on('error', (err) => {
   if ((err as any).code === CONNECTION_REFUSED) {

packages/backend/src/workers/processor.ts

@@ -24,3 +24,7 @@ worker.on('failed', (job, err) => {
     `JOB ID: ${job.id} - FLOW ID: ${job.data.flowId} has failed with ${err.message}`
   );
 });
+
+process.on('SIGTERM', async () => {
+  await worker.close();
+});