fix(worker): close promotion scanner queue on SIGTERM

This commit is contained in:
Zac Gaetano 2026-06-04 14:06:41 +00:00
parent d3e520e3b1
commit e45de85512

View file

@ -141,6 +141,7 @@ process.on('SIGTERM', async () => {
proxyThumbnailQueue.close().catch(() => {}), proxyThumbnailQueue.close().catch(() => {}),
youtubeProxyQueue.close().catch(() => {}), youtubeProxyQueue.close().catch(() => {}),
filmstripQueue.close().catch(() => {}), filmstripQueue.close().catch(() => {}),
_promotionScanner ? _promotionScanner.promotionQueue.close().catch(() => {}) : Promise.resolve(),
]); ]);
console.log('All workers and queues closed'); console.log('All workers and queues closed');