From 85ff0c311e0f94c238dc4fb1d48f7e8ffd324be9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= <mo.geryy@gmail.com>
Date: Wed, 21 Aug 2024 19:21:29 +0200
Subject: [PATCH] Add worker ID to job attribute

---
 apps/api/src/services/queue-worker.ts | 1 +
 1 file changed, 1 insertion(+)

diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts
index 7d4beef1..2086d0a6 100644
--- a/apps/api/src/services/queue-worker.ts
+++ b/apps/api/src/services/queue-worker.ts
@@ -109,6 +109,7 @@ const workerFun = async (queueName: string, processJobInternal: (token: string,
         op: "bullmq.job",
         attributes: {
           job: job.id,
+          worker: process.env.FLY_MACHINE_ID ?? worker.id,
         },
       }, async () => {
         await processJobInternal(token, job);