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

33 lines
991 B
Python

import logging
from core.runtime.managefailure import manageFailure
from core.execution.action.action import buildAction
#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 = []
for action in actions:
#if action == "recursiveset":
#if hasattr(action, "recursiveset"):
# from core.runtime.recursive import recursiveSet
# outputs, responses = recursiveSet(action, outputs, responses)
#else:
#outputs, response = buildAction(action, outputs)
outputs, response = executeContract(action, outputs)
#if hasattr(action, recursive)
responses.append(response)
#except Exception as error:
#outputs = manageFailure(error, action, outputs)
return outputs, responses