Skip to content
Snippets Groups Projects

don't send QA messaging for observation ingestions

Merged Charlotte Hausman requested to merge tweak-ingest-message-catching into 2.8.2-DEVELOPMENT
All threads resolved!
1 file
+ 2
2
Compare changes
  • Side-by-side
  • Inline
@@ -836,7 +836,7 @@ class WorkflowMessageHandler:
wf_req_id = subject["workflow_request_id"]
wf_request = self.info.lookup_workflow_request(wf_req_id)
if "ingest" in wf_request.workflow_name:
if "ingest" in wf_request.workflow_name and "obs" not in wf_request.workflow_name:
if "seci" not in wf_request.workflow_name:
subject["execution_wf_id"] = wf_request.argument["parent_wf_request_id"]
logger.debug("Sending ingestion complete message!")
@@ -867,7 +867,7 @@ class WorkflowMessageHandler:
wf_req_id = subject["workflow_request_id"]
wf_request = self.info.lookup_workflow_request(wf_req_id)
if "ingest" in wf_request.workflow_name:
if "ingest" in wf_request.workflow_name and "obs" not in wf_request.workflow_name:
if "seci" not in wf_request.workflow_name:
subject["execution_wf_id"] = wf_request.argument["parent_wf_request_id"]
logger.debug("Sending ingestion failed message!")
Loading