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);