service: runs: pass run queue to task

inveniosoftware · Jun 5, 2024 · 8888648 · 8888648
1 parent bc881ed
commit 8888648
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/invenio_jobs/services/services.py b/invenio_jobs/services/services.py
@@ -251,6 +251,7 @@ def create(self, identity, job_id, data, uow=None):
                 execute_run,
                 kwargs={"run_id": run.id, "kwargs": run.args},
                 task_id=str(run.task_id),
+                queue=run.queue,
             )
         )