Skip to content

Commit 41b5bf8

Browse files
committed
Fix missing workers
1 parent 23950dc commit 41b5bf8

2 files changed

Lines changed: 3 additions & 6 deletions

File tree

src/hooks.server.ts

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,7 @@ if (!building) {
3737
// Graceful shutdown
3838
process.on('sveltekit:shutdown', async () => {
3939
OTEL.instance.logger.info('Shutting down gracefully...');
40-
await Promise.all(
41-
allWorkers.map((worker) => {
42-
worker.worker?.close();
43-
})
44-
);
40+
await Promise.all(allWorkers.map((worker) => worker.worker?.close()));
4541
});
4642
}
4743

src/lib/server/bullmq/BullMQ.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,5 +8,6 @@ export const allWorkers = building
88
new Workers.S3(),
99
new Workers.Releases(),
1010
new Workers.Polling(),
11-
new Workers.SystemStartup()
11+
new Workers.SystemStartup(),
12+
new Workers.SystemRecurring()
1213
];

0 commit comments

Comments
 (0)