WS-1082: register cube workflow
2 unresolved threads
2 unresolved threads
Merge request reports
Activity
971 978 ) 972 979 self.archive_messenger.send_message(**seci_msg) 973 980 981 if wf_request.workflow_name == ArchiveWorkflows.SECI.value: changed this line in version 2 of the diff
957 957 "seci_failed" 958 958 ) 959 959 self.archive_messenger.send_message(**seci_msg) 960 if wf_request.workflow_name == ArchiveWorkflows.CUBE.value: 961 logger.info(f"SENDING FAILED COARSE CUBE MESSAGE to VLASS Manager for request #{wf_id}!") 962 routing_key = f"ws-workflow.coarse_cube.{wf_id}" 963 seci_msg = ArchiveMessageArchitect(routing_key=routing_key, request=wf_request).compose_message( changed this line in version 3 of the diff
Please register or sign in to reply