From e45de85512e5cb68721a019a1b0a8ab5449eccb3 Mon Sep 17 00:00:00 2001 From: ZGaetano Date: Thu, 4 Jun 2026 14:06:41 +0000 Subject: [PATCH] fix(worker): close promotion scanner queue on SIGTERM --- services/worker/src/index.js | 1 + 1 file changed, 1 insertion(+) diff --git a/services/worker/src/index.js b/services/worker/src/index.js index 581ecfc..1b66ec2 100644 --- a/services/worker/src/index.js +++ b/services/worker/src/index.js @@ -141,6 +141,7 @@ process.on('SIGTERM', async () => { proxyThumbnailQueue.close().catch(() => {}), youtubeProxyQueue.close().catch(() => {}), filmstripQueue.close().catch(() => {}), + _promotionScanner ? _promotionScanner.promotionQueue.close().catch(() => {}) : Promise.resolve(), ]); console.log('All workers and queues closed');