Fixed dataset parameters. They weren't being included in rabbtimq message. (#957)

lmarini · web-flow · commit 5f55c4022961 · 2024-03-04T13:29:19.000-06:00
diff --git a/backend/app/rabbitmq/listeners.py b/backend/app/rabbitmq/listeners.py
@@ -111,6 +111,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(

Original file line number	Diff line number	Diff line change
`@@ -111,6 +111,7 @@ async def submit_dataset_job(`
`111`	`111`	`datasetId=str(dataset_out.id),`
`112`	`112`	`secretKey=current_secretKey,`
`113`	`113`	`job_id=str(job.id),`
	`114`	`+ parameters=parameters,`
`114`	`115`	`)`
`115`	`116`	`reply_to = await create_reply_queue()`
`116`	`117`	`rabbitmq_client.basic_publish(`