feat(api): active and completed jobs metric services health indicators

novuhq · Sep 14, 2023 · 4c487a5 · 4c487a5
1 parent e8986b8
commit 4c487a5
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/apps/worker/src/app/health/health.controller.ts b/apps/worker/src/app/health/health.controller.ts
@@ -5,6 +5,8 @@ import {
   DalServiceHealthIndicator,
   StandardQueueServiceHealthIndicator,
   WorkflowQueueServiceHealthIndicator,
+  ActiveJobsMetricQueueServiceHealthIndicator,
+  CompletedJobsMetricQueueServiceHealthIndicator,
 } from '@novu/application-generic';
 
 import { version } from '../../../package.json';
@@ -16,7 +18,9 @@ export class HealthController {
     private healthCheckService: HealthCheckService,
     private dalHealthIndicator: DalServiceHealthIndicator,
     private standardQueueHealthIndicator: StandardQueueServiceHealthIndicator,
-    private workflowQueueHealthIndicator: WorkflowQueueServiceHealthIndicator
+    private workflowQueueHealthIndicator: WorkflowQueueServiceHealthIndicator,
+    private activeJobsMetricQueueServiceHealthIndicator: ActiveJobsMetricQueueServiceHealthIndicator,
+    private completedJobsMetricQueueServiceHealthIndicator: CompletedJobsMetricQueueServiceHealthIndicator
   ) {}
 
   @Get()
@@ -26,6 +30,8 @@ export class HealthController {
       async () => this.dalHealthIndicator.isHealthy(),
       async () => this.standardQueueHealthIndicator.isHealthy(),
       async () => this.workflowQueueHealthIndicator.isHealthy(),
+      async () => this.activeJobsMetricQueueServiceHealthIndicator.isHealthy(),
+      async () => this.completedJobsMetricQueueServiceHealthIndicator.isHealthy(),
       async () => {
         return {
           apiVersion: {

diff --git a/packages/application-generic/src/modules/queues.module.ts b/packages/application-generic/src/modules/queues.module.ts
@@ -34,10 +34,12 @@ import {
 
 const PROVIDERS: Provider[] = [
   ActiveJobsMetricQueueService,
+  ActiveJobsMetricQueueServiceHealthIndicator,
   ActiveJobsMetricWorkerService,
   bullMqTokenList,
   BullMqService,
   CompletedJobsMetricQueueService,
+  CompletedJobsMetricQueueServiceHealthIndicator,
   CompletedJobsMetricWorkerService,
   InboundParseQueue,
   InboundParseWorker,