Skip to content
Snippets Groups Projects
Commit 677ef939 authored by Janet Goldstein's avatar Janet Goldstein
Browse files

WS-858: correct keyword

parent 9ff5a2a1
No related branches found
No related tags found
1 merge request!718WS-858: fix bugs in `create_follow_on_capability_request`, hopefully for the last time
...@@ -154,7 +154,7 @@ def create_follow_on_capability_request(request: Request) -> Response: ...@@ -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"] sdm_id = metadata["fileSetIds"][0] if isinstance(metadata["fileSetIds"], list) else metadata["fileSetIds"]
new_capability_request = request.capability_info.create_capability_request( new_capability_request = request.capability_info.create_capability_request(
followon_type=followon_type, capability_name=followon_type,
parameters={ parameters={
"user_email": user_email, "user_email": user_email,
"version": version_number, "version": version_number,
......
...@@ -378,7 +378,7 @@ class WorkflowService(WorkflowServiceIF): ...@@ -378,7 +378,7 @@ class WorkflowService(WorkflowServiceIF):
argument2 = [wf_request.argument["cal_locator"]] argument2 = [wf_request.argument["cal_locator"]]
elif "imaging" in name: elif "imaging" in name:
wrest_type = "-si" wrest_type = "-si"
argument = wf_request.argument["sdmId"] argument = wf_request.argument["sdm_id"]
argument2 = [] argument2 = []
elif "carta" in name: elif "carta" in name:
wrest_type = "--carta" wrest_type = "--carta"
...@@ -700,7 +700,7 @@ class WorkflowMessageHandler: ...@@ -700,7 +700,7 @@ class WorkflowMessageHandler:
subject = message["subject"] subject = message["subject"]
wf_req_id = subject["workflow_request_id"] wf_req_id = subject["workflow_request_id"]
wf_request = self.info.lookup_workflow_request(wf_req_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: if "ingest" in wf_request.workflow_name:
logger.info("SENDING INGESTION FAILED MESSAGE!") logger.info("SENDING INGESTION FAILED MESSAGE!")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment