diff --git a/backend/app/rabbitmq/listeners.py b/backend/app/rabbitmq/listeners.py index 66a529dd9..f0cfd5a7f 100644 --- a/backend/app/rabbitmq/listeners.py +++ b/backend/app/rabbitmq/listeners.py @@ -112,6 +112,7 @@ async def submit_dataset_job( datasetId=str(dataset_out.id), secretKey=current_secretKey, job_id=str(job.id), + parameters=parameters, ) reply_to = await create_reply_queue() rabbitmq_client.basic_publish(