fixed some issues, testing shutdown

This commit is contained in:
Boki 2025-06-20 17:56:45 -04:00
parent dbfa80b2a2
commit 0497541a47
11 changed files with 15 additions and 800 deletions

View file

@ -228,7 +228,11 @@ export class Queue {
// Close workers first
if (this.workers.length > 0) {
await Promise.all(this.workers.map(worker => worker.close()));
await Promise.all(
this.workers.map(async worker => {
return await worker.close();
})
);
this.workers = [];
logger.debug('Workers closed', { queueName: this.queueName });
}