diff --git a/shared/workspaces/workspaces/workflow/services/workflow_service.py b/shared/workspaces/workspaces/workflow/services/workflow_service.py index c9345f8b24ea193901aa9c725d9b32a20946cee6..6c1a10fba9ff890bd478dc1db26c7b34db90aaf7 100644 --- a/shared/workspaces/workspaces/workflow/services/workflow_service.py +++ b/shared/workspaces/workspaces/workflow/services/workflow_service.py @@ -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!")