Skip to content
Snippets Groups Projects

fix CapabilityEngine

Merged Charlotte Hausman requested to merge SSA-6696-capability-queues into main
1 unresolved thread
Files
2
@@ -22,17 +22,24 @@ class CapabilityEngine(CapabilityEngineIF):
@@ -22,17 +22,24 @@ class CapabilityEngine(CapabilityEngineIF):
):
):
self.capability_info = capability_info
self.capability_info = capability_info
self.workflow_service = workflow_service
self.workflow_service = workflow_service
 
self.execution = None
def execute(self, execution: CapabilityExecutionIF):
def load_engine(self, execution: CapabilityExecutionIF):
"""
"""
Communicate with workflow service and send a request to run a workflow with given settings
Load capability execution of interest into capability engine for access and execution
 
:param execution: execution to be executed by this engine
 
:return:
 
"""
 
self.execution = execution
:param execution:
def execute(self):
 
"""
 
Communicate with workflow service and send a request to run a workflow with given settings
"""
"""
step_sequence = CapabilitySequence.from_str(execution.steps)
step_sequence = CapabilitySequence.from_str(self.execution.steps)
# Grab value of current step (workflow name)
# Grab value of current step (workflow name)
cur_step = step_sequence[int(execution.current_step)]
cur_step = step_sequence[int(self.execution.current_step)]
cur_step.execute(self, execution)
cur_step.execute(self, self.execution)
def submit_workflow_request(
def submit_workflow_request(
self, execution_id: int, workflow_name: str, workflow_args: dict, files: List[AbstractFile]
self, execution_id: int, workflow_name: str, workflow_args: dict, files: List[AbstractFile]
Loading