We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8244afb commit a562137Copy full SHA for a562137
services/workflows-service/src/common/queue/queue.service.ts
@@ -243,8 +243,6 @@ export class QueueService implements OnModuleDestroy {
243
}
244
245
async onModuleDestroy() {
246
- this.logger.log('Closing all queues and workers');
247
-
248
const workerClosePromises = Array.from(this.workers.values()).map(worker =>
249
worker.close().catch(err => this.logger.error(`Error closing worker`, { err })),
250
);
@@ -261,7 +259,5 @@ export class QueueService implements OnModuleDestroy {
261
259
.catch(err => this.logger.error(`Error closing Redis connection`, { err }));
262
260
this.redisClient = null;
263
264
265
- this.logger.log('All queues and workers closed');
266
267
0 commit comments