Add better per job metrics and UI (#603)

parcelvoy · Jan 4, 2025 · b921fef · b921fef
1 parent 27a457b
commit b921fef
Show file tree

Hide file tree

Showing 12 changed files with 445 additions and 292 deletions.
diff --git a/apps/platform/src/organizations/OrganizationController.ts b/apps/platform/src/organizations/OrganizationController.ts
@@ -34,7 +34,17 @@ router.get('/performance/jobs', async ctx => {
 })
 
 router.get('/performance/jobs/:job', async ctx => {
-    ctx.body = await App.main.stats.list(ctx.params.job)
+    const jobName = ctx.params.job
+    ctx.body = [
+        {
+            label: 'added',
+            data: await App.main.stats.list(jobName),
+        },
+        {
+            label: 'completed',
+            data: await App.main.stats.list(`${jobName}:completed`),
+        },
+    ]
 })
 
 router.get('/performance/failed', async ctx => {

diff --git a/apps/platform/src/queue/Queue.ts b/apps/platform/src/queue/Queue.ts
@@ -82,6 +82,7 @@ export default class Queue {
 
     async completed(job: EncodedJob) {
         logger.trace(job, 'queue:job:completed')
+        await App.main.stats.increment(`${job.name}:completed`)
     }
 
     async start() {