From ff940e477192c568a9977666c974ee1ea9ae1eda Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Wed, 28 Oct 2026 11:17:10 -0400 Subject: [PATCH] Cleaned process registry and added process to post runtime processing for post runtime stop signal registration --- core/execution/processregistry.py | 4 ---- core/runtime/runtimecontract.py | 4 ++-- 2 files changed, 2 insertions(+), 6 deletions(-) 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)