Skip to content
Snippets Groups Projects
Commit acf29738 authored by Jim Sheckard's avatar Jim Sheckard
Browse files

WS-1073 update workflow service code to run wrester for cubes

parent 586d4cf1
No related branches found
No related tags found
1 merge request!972WS-1073 update workflow service code to run wrester for cubes
Pipeline #5589 passed
......@@ -134,7 +134,7 @@ class WorkflowServiceRESTClient(WorkflowServiceIF):
result = requests.post(f"{self.url}/workflows/requests/{workflow_request_id}/qa/{msg_type}", json=argument)
return WorkflowRequest.from_json(result)
return WorkflowRequest.from_json(result.json())
def ingest(self, request: WorkflowRequest):
"""
......@@ -456,6 +456,10 @@ class WorkflowService(WorkflowServiceIF):
wrest_type = "--carta"
argument = wf_request.argument["product_locator"].split()[1]
argument2 = []
elif "coarse" in name:
wrest_type = "--cube"
argument = wf_request.argument["precursor"]
argument2 = []
elif "ingest" in name:
wrest_type = "-aux"
if "seci" in name:
......
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