diff --git a/core/execution/processregistry.py b/core/execution/processregistry.py index 96b815d..3319885 100644 --- a/core/execution/processregistry.py +++ b/core/execution/processregistry.py @@ -1,10 +1,6 @@ def registerProcess(module, outputs): if not "processes" in outputs: outputs["processes"] = {} - #outputs["processes"] = {module.name: {}} - - #print("WHERE IS MY PROCESS DICT?") - #print(outputs) if not module.name in outputs["processes"]: outputs["processes"][module.name] = {} diff --git a/core/runtime/runtimecontract.py b/core/runtime/runtimecontract.py index fe5f8d5..46a0c24 100644 --- a/core/runtime/runtimecontract.py +++ b/core/runtime/runtimecontract.py @@ -22,7 +22,7 @@ def buildPreRuntimeAttr(action, outputs, process): return outputs, resolved, match, filter -def buildRuntimeAttr(action, outputs, resolved, response): +def buildRuntimeAttr(action, outputs, resolved, response, process): outputs = responsePolicy(response, action, outputs, resolved) #print(f"Response status code: {response.status_code} during {action.name}") @@ -31,7 +31,7 @@ def buildRuntimeAttr(action, outputs, resolved, response): outputs = buildOutput(response, action, outputs) if not response.ok: - outputs = addStopSignal(action, outputs) + outputs = addStopSignal(action, outputs, process) return outputs, response resolved = extractItem(action, outputs, resolved)