david/rmmanager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Cleaned process registry and added process to post runtime processing for post runtime stop signal registration

Browse Source
This commit is contained in:
Lyncoln
2026-10-28 11:17:10 -04:00
parent 3582c7b621
commit ff940e4771
2 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/execution/processregistry.py
-4
View File
@@ -1,10 +1,6 @@
def registerProcess(module, outputs): def registerProcess(module, outputs):
if not "processes" in outputs: if not "processes" in outputs:
outputs["processes"] = {} outputs["processes"] = {}
#outputs["processes"] = {module.name: {}}
#print("WHERE IS MY PROCESS DICT?")
#print(outputs)
if not module.name in outputs["processes"]: if not module.name in outputs["processes"]:
outputs["processes"][module.name] = {} outputs["processes"][module.name] = {}
core/runtime/runtimecontract.py
+2 -2
View File
@@ -22,7 +22,7 @@ def buildPreRuntimeAttr(action, outputs, process):
return outputs, resolved, match, filter return outputs, resolved, match, filter
def buildRuntimeAttr(action, outputs, resolved, response): def buildRuntimeAttr(action, outputs, resolved, response, process):
outputs = responsePolicy(response, action, outputs, resolved) outputs = responsePolicy(response, action, outputs, resolved)
#print(f"Response status code: {response.status_code} during {action.name}") #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) outputs = buildOutput(response, action, outputs)
if not response.ok: if not response.ok:
outputs = addStopSignal(action, outputs) outputs = addStopSignal(action, outputs, process)
return outputs, response return outputs, response
resolved = extractItem(action, outputs, resolved) resolved = extractItem(action, outputs, resolved)