From 28bd77fc448d0c9133ff597e331e6eb70c0d1542 Mon Sep 17 00:00:00 2001
From: chausman <chausman@nrao.edu>
Date: Fri, 5 Feb 2021 09:21:53 -0700
Subject: [PATCH] SWS-6: workflows now start correctly with correct arguments
---
services/capability/src/capability/server.py | 2 +-
shared/workspaces/workspaces/capability/helpers.py | 9 +++++----
2 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/services/capability/src/capability/server.py b/services/capability/src/capability/server.py
index 518baa3b1..fd99f5876 100644
--- a/services/capability/src/capability/server.py
+++ b/services/capability/src/capability/server.py
@@ -51,7 +51,7 @@ class CapabilityRestService:
def create(self):
# create a capability request for this ... request
req = self.request.json_body
- request = self.request.capabilities.create_request(req["capability"])
+ request = self.request.capabilities.create_request(req["capability"], req["args"])
return request
@view_config(
diff --git a/shared/workspaces/workspaces/capability/helpers.py b/shared/workspaces/workspaces/capability/helpers.py
index 33aa82189..7cbd9e721 100644
--- a/shared/workspaces/workspaces/capability/helpers.py
+++ b/shared/workspaces/workspaces/capability/helpers.py
@@ -114,12 +114,13 @@ class CapabilitySequence(CapabilitySequenceIF):
class PrepareAndRunWorkflow(CapabilityStep):
def execute(self, engine: CapabilityEngineIF, execution: CapabilityExecutionIF):
workflow_name = self.step_value
- workflow_args = self.step_args
+ parameters = execution.capability_request.parameters
# FIXME: Add support for files
files = []
- if workflow_args is not None:
- workflow_args = json.loads(workflow_args)
- engine.submit_workflow_request(workflow_name, workflow_args, files)
+ if parameters is not None:
+ parameters = json.dumps(parameters) # convert to json string
+ workflow_args = json.loads(parameters)
+ engine.submit_workflow_request(execution.id, workflow_name, workflow_args, files)
class AwaitQa(CapabilityStep):
--
GitLab