Files
rmmanager/core/execution/operation/operation.py
T

34 lines
967 B
Python

import logging
from core.runtime.managefailure import manageFailure
from core.execution.action.action import buildAction
from core.runtime.stopsignals import checkDependency
#from core.runtime.skipstep import skipStep
#from core.runtime.recursive import recursiveSet
outputs = {}
def buildOperation(definition, outputs):
from core.execution.executioncontract import executeContract
actions = definition.actions
responses = []
outputs["stopsignals"] = []
for action in actions:
stop = checkDependency(action, outputs)
#print(f"STOP SIGNAL DEBUGGING during {action.name}")
#print(outputs["stopsignals"])
if stop:
continue
outputs, response = executeContract(action, outputs)
#if hasattr(action, recursive)
responses.append(response)
#except Exception as error:
#outputs = manageFailure(error, action, outputs)
return outputs, responses