@@ -649,7 +649,7 @@ def _register_incomplete_2d_batch(message: dict, _db):
649649 ),
650650 "node_creator_queue" : machine_config .node_creator_queue ,
651651 },
652- "recipes" : ["em-spa-class2d" ],
652+ "recipes" : [machine_config . recipes . get ( "em-spa-class2d" , "em-spa-class2d" ) ],
653653 }
654654 if murfey .server ._transport_object :
655655 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -800,7 +800,7 @@ def _register_complete_2d_batch(message: dict, _db):
800800 ),
801801 "node_creator_queue" : machine_config .node_creator_queue ,
802802 },
803- "recipes" : ["em-spa-class2d" ],
803+ "recipes" : [machine_config . recipes . get ( "em-spa-class2d" , "em-spa-class2d" ) ],
804804 }
805805 if murfey .server ._transport_object :
806806 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -875,7 +875,7 @@ def _register_complete_2d_batch(message: dict, _db):
875875 ),
876876 "node_creator_queue" : machine_config .node_creator_queue ,
877877 },
878- "recipes" : ["em-spa-class2d" ],
878+ "recipes" : [machine_config . recipes . get ( "em-spa-class2d" , "em-spa-class2d" ) ],
879879 }
880880 if murfey .server ._transport_object :
881881 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -965,7 +965,7 @@ def _flush_class2d(
965965 "autoproc_program_id" : _app_id (pj_id , _db ),
966966 "node_creator_queue" : machine_config .node_creator_queue ,
967967 },
968- "recipes" : ["em-spa-class2d" ],
968+ "recipes" : [machine_config . recipes . get ( "em-spa-class2d" , "em-spa-class2d" ) ],
969969 }
970970 if murfey .server ._transport_object :
971971 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -1283,7 +1283,7 @@ def _register_3d_batch(message: dict, _db):
12831283 ),
12841284 "node_creator_queue" : machine_config .node_creator_queue ,
12851285 },
1286- "recipes" : ["em-spa-class3d" ],
1286+ "recipes" : [machine_config . recipes . get ( "em-spa-class3d" , "em-spa-class3d" ) ],
12871287 }
12881288 if murfey .server ._transport_object :
12891289 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -1326,7 +1326,7 @@ def _register_3d_batch(message: dict, _db):
13261326 ),
13271327 "node_creator_queue" : machine_config .node_creator_queue ,
13281328 },
1329- "recipes" : ["em-spa-class3d" ],
1329+ "recipes" : [machine_config . recipes . get ( "em-spa-class3d" , "em-spa-class3d" ) ],
13301330 }
13311331 if murfey .server ._transport_object :
13321332 zocalo_message ["parameters" ]["feedback_queue" ] = (
@@ -1631,7 +1631,7 @@ def _register_refinement(message: dict, _db):
16311631 _pj_id (message ["program_id" ], _db , recipe = "em-spa-refine" ), _db
16321632 ),
16331633 },
1634- "recipes" : ["em-spa-refine" ],
1634+ "recipes" : [machine_config . recipes . get ( "em-spa-refine" , "em-spa-refine" ) ],
16351635 }
16361636 if murfey .server ._transport_object :
16371637 zocalo_message ["parameters" ]["feedback_queue" ] = (
0 commit comments