diff options
| author | dakkar <dakkar@thenautilus.net> | 2024-12-21 16:35:51 +0000 |
|---|---|---|
| committer | dakkar <dakkar@thenautilus.net> | 2024-12-21 16:35:51 +0000 |
| commit | 5eca807e19f55c99ae5ca4d4e3c2179c3c908368 (patch) | |
| tree | a7774cd40f4fa90cd8c1fe60e644e075806034f3 /packages/backend/src | |
| parent | merge: Sync charts one-at-a-time to reduce database contention and timeouts (... (diff) | |
| parent | Revert "Synchronize server startup" (diff) | |
| download | sharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.tar.gz sharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.tar.bz2 sharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.zip | |
merge: Revert "Synchronize server startup" (!831)
View MR for information: https://activitypub.software/TransFem-org/Sharkey/-/merge_requests/831
Approved-by: dakkar <dakkar@thenautilus.net>
Approved-by: Charlotte <timo.herngreen@gmail.com>
Diffstat (limited to 'packages/backend/src')
| -rw-r--r-- | packages/backend/src/boot/common.ts | 17 | ||||
| -rw-r--r-- | packages/backend/src/daemons/QueueStatsService.ts | 4 | ||||
| -rw-r--r-- | packages/backend/src/daemons/ServerStatsService.ts | 2 |
3 files changed, 11 insertions, 12 deletions
diff --git a/packages/backend/src/boot/common.ts b/packages/backend/src/boot/common.ts index 9ff1efb3c2..ad59a55688 100644 --- a/packages/backend/src/boot/common.ts +++ b/packages/backend/src/boot/common.ts @@ -19,18 +19,17 @@ export async function server() { logger: new NestLogger(), }); + const serverService = app.get(ServerService); + await serverService.launch(); + if (process.env.NODE_ENV !== 'test') { - await app.get(ChartManagementService).start(); + app.get(ChartManagementService).start(); } if (!envOption.noDaemons) { - await app.get(QueueStatsService).start(); - await app.get(ServerStatsService).start(); + app.get(QueueStatsService).start(); + app.get(ServerStatsService).start(); } - // Start server last so the other services can register hooks first - const serverService = app.get(ServerService); - await serverService.launch(); - return app; } @@ -39,8 +38,8 @@ export async function jobQueue() { logger: new NestLogger(), }); - await jobQueue.get(QueueProcessorService).start(); - await jobQueue.get(ChartManagementService).start(); + jobQueue.get(QueueProcessorService).start(); + jobQueue.get(ChartManagementService).start(); return jobQueue; } diff --git a/packages/backend/src/daemons/QueueStatsService.ts b/packages/backend/src/daemons/QueueStatsService.ts index 77fcd71337..ede104b9fe 100644 --- a/packages/backend/src/daemons/QueueStatsService.ts +++ b/packages/backend/src/daemons/QueueStatsService.ts @@ -33,7 +33,7 @@ export class QueueStatsService implements OnApplicationShutdown { * Report queue stats regularly */ @bindThis - public async start(): Promise<void> { + public start(): void { const log = [] as any[]; ev.on('requestQueueStatsLog', x => { @@ -82,7 +82,7 @@ export class QueueStatsService implements OnApplicationShutdown { activeInboxJobs = 0; }; - await tick(); + tick(); this.intervalId = setInterval(tick, interval); } diff --git a/packages/backend/src/daemons/ServerStatsService.ts b/packages/backend/src/daemons/ServerStatsService.ts index 2ab087477a..6e9d29dcbd 100644 --- a/packages/backend/src/daemons/ServerStatsService.ts +++ b/packages/backend/src/daemons/ServerStatsService.ts @@ -68,7 +68,7 @@ export class ServerStatsService implements OnApplicationShutdown { if (log.length > 200) log.pop(); }; - await tick(); + tick(); this.intervalId = setInterval(tick, interval); } |