Skip to content

Commit 1638a89

Browse files
author
Florian Perucki
committed
add initial queue info in raw task jobs
1 parent 3f23427 commit 1638a89

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

mrq/queue.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -499,6 +499,7 @@ def dequeue_jobs(self, max_jobs=1, job_class=None, worker=None):
499499
for j in job_data:
500500
j["status"] = "started"
501501
j["queue"] = retry_queue
502+
j["raw_queue"] = self.id
502503
if worker:
503504
j["worker"] = worker.id
504505

0 commit comments

Comments
 (0)