chore: exec lint:fix

lokalise · Aug 6, 2024 · 115cd7d · 115cd7d
1 parent b4030c0
commit 115cd7d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 7 deletions.
diff --git a/lib/plugins/bull-mq-metrics/ObservableQueue.ts b/lib/plugins/bull-mq-metrics/ObservableQueue.ts
@@ -1,5 +1,5 @@
 import { Queue, QueueEvents } from 'bullmq'
-import type { FinishedStatus } from "bullmq";
+import type { FinishedStatus } from 'bullmq'
 import type { FastifyBaseLogger } from 'fastify'
 import type { Redis } from 'ioredis'
 
@@ -18,13 +18,13 @@ export class ObservableQueue {
       }
 
       this.metrics.finishedDuration
-          .labels({ status, queue: this.name })
-          .observe(job.finishedOn - job.timestamp)
+        .labels({ status, queue: this.name })
+        .observe(job.finishedOn - job.timestamp)
 
       if (job.processedOn) {
         this.metrics.processedDuration
-            .labels({ status, queue: this.name })
-            .observe(job.finishedOn - job.processedOn)
+          .labels({ status, queue: this.name })
+          .observe(job.finishedOn - job.processedOn)
       }
     } catch (err) {
       this.logger.warn(err)

diff --git a/lib/plugins/bullMqMetricsPlugin.spec.ts b/lib/plugins/bullMqMetricsPlugin.spec.ts
@@ -138,7 +138,9 @@ describe('bullMqMetricsPlugin', () => {
     await app.bullMqMetrics.collect()
 
     const responseBefore = await getMetrics()
-    expect(responseBefore.result.body).not.toContain('bullmq_jobs_finished_duration_count{status="completed",queue="test_job"} 1')
+    expect(responseBefore.result.body).not.toContain(
+      'bullmq_jobs_finished_duration_count{status="completed",queue="test_job"} 1',
+    )
 
     await processor.schedule({
       metadata: {
@@ -151,6 +153,8 @@ describe('bullMqMetricsPlugin', () => {
     await app.bullMqMetrics.collect()
 
     const responseAfter = await getMetrics()
-    expect(responseAfter.result.body).toContain('bullmq_jobs_finished_duration_count{status="completed",queue="test_job"} 1')
+    expect(responseAfter.result.body).toContain(
+      'bullmq_jobs_finished_duration_count{status="completed",queue="test_job"} 1',
+    )
   })
 })