diff --git a/core/execution/executioncontract.py b/core/execution/executioncontract.py index 0bb2718..0bac0d9 100644 --- a/core/execution/executioncontract.py +++ b/core/execution/executioncontract.py @@ -3,20 +3,16 @@ from core.execution.operation import buildOperation from core.execution.monitor import buildMonitor #from core.runtime import manageFailure from core.execution.recursive import buildRecursive -#from core.runtime.createruntime import outputs - -def executeContract(module, outputs): - #print(outputs) +from core.runtime.createruntime import outputs +def executeContract(module): if module.kind == "operation": - responses = buildOperation(module, outputs) return responses elif module.kind == "action": - response = buildAction(module, outputs) return response diff --git a/core/execution/lifecyclemanager/lifecyclemanager.py b/core/execution/lifecyclemanager/lifecyclemanager.py index 2faf25d..174d3bc 100644 --- a/core/execution/lifecyclemanager/lifecyclemanager.py +++ b/core/execution/lifecyclemanager/lifecyclemanager.py @@ -18,7 +18,7 @@ def manageLifecycle(module): while lifecycles[module.name]["mode"] == "continuous": lifecycles[module.name]["state"] = "active" - response = executeContract(module, outputs) + executeContract(module) if lifecycle_log: print(f"{module.name} thread {lifecycles[module.name][module.name]} running in {lifecycles[module.name]['mode']} mode") @@ -35,7 +35,7 @@ def manageLifecycle(module): print(f"{module.name} thread {lifecycles[module.name][module.name]} running in {lifecycles[module.name]['mode']} mode") print(lifecycles) - response = executeContract(module, outputs) + response = executeContract(module) lifecycles[module.name]["state"] = "stopped"