Add worker ID to job attribute
This commit is contained in:
@@ -109,6 +109,7 @@ const workerFun = async (queueName: string, processJobInternal: (token: string,
|
|||||||
op: "bullmq.job",
|
op: "bullmq.job",
|
||||||
attributes: {
|
attributes: {
|
||||||
job: job.id,
|
job: job.id,
|
||||||
|
worker: process.env.FLY_MACHINE_ID ?? worker.id,
|
||||||
},
|
},
|
||||||
}, async () => {
|
}, async () => {
|
||||||
await processJobInternal(token, job);
|
await processJobInternal(token, job);
|
||||||
|
|||||||
Reference in New Issue
Block a user