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');