diff --git a/services/capability/capability/views/capability_request.py b/services/capability/capability/views/capability_request.py index 8311d66788c90d34638ada52aa0913758473537a..abca1cc8c7191a72b8366b6acf8fe1c0c7195935 100644 --- a/services/capability/capability/views/capability_request.py +++ b/services/capability/capability/views/capability_request.py @@ -154,7 +154,7 @@ def create_follow_on_capability_request(request: Request) -> Response: sdm_id = metadata["fileSetIds"][0] if isinstance(metadata["fileSetIds"], list) else metadata["fileSetIds"] new_capability_request = request.capability_info.create_capability_request( - followon_type=followon_type, + capability_name=followon_type, parameters={ "user_email": user_email, "version": version_number, diff --git a/shared/workspaces/workspaces/workflow/services/workflow_service.py b/shared/workspaces/workspaces/workflow/services/workflow_service.py index bd1d90cacb82c487f4060cb48ab9e50d4d7879f9..00ac7f463fe2b82097bfdd128a1850888661f4ea 100644 --- a/shared/workspaces/workspaces/workflow/services/workflow_service.py +++ b/shared/workspaces/workspaces/workflow/services/workflow_service.py @@ -378,7 +378,7 @@ class WorkflowService(WorkflowServiceIF): argument2 = [wf_request.argument["cal_locator"]] elif "imaging" in name: wrest_type = "-si" - argument = wf_request.argument["sdmId"] + argument = wf_request.argument["sdm_id"] argument2 = [] elif "carta" in name: wrest_type = "--carta" @@ -700,7 +700,7 @@ class WorkflowMessageHandler: subject = message["subject"] wf_req_id = subject["workflow_request_id"] wf_request = self.info.lookup_workflow_request(wf_req_id) - subject["execution_wf_id"] = wf_request.argument["parent_wf_request_id"] + subject["execution_wf_id"] = wf_request.argument["previous_workflow_request_id"] if "ingest" in wf_request.workflow_name: logger.info("SENDING INGESTION FAILED MESSAGE!")