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