Stopped returning outputs for registerProcess

This commit is contained in:
Lyncoln
2026-10-28 17:44:09 -04:00
parent d492d78a70
commit 950707386a
3 changed files with 3 additions and 10 deletions
+1 -8
View File
@@ -18,37 +18,30 @@ def buildOperation(definition, outputs):
from core.execution.executioncontract import executeContract
actions = definition.actions
outputs = registerProcess(definition, outputs)
registerProcess(definition, outputs)
responses = []
if getattr(definition, "track", False):
actions = track(
actions,
#description=definition.name
description=f"[green]{definition.name}[/green]",
console=console
)
for action in actions:
#Check if dependencies are in stop signal registry
stop = checkDependency(action, outputs, definition)
if stop:
continue
#Register action before its execution
if action.kind == "action":
outputs["processes"][definition.name][action.name] = {}
#Pass the definition through to the action so it can be passed into buildPreRuntimeAttr
#Definition should be passed through in order to give access to addStopSignal so it can write directly to the definition during buildPreRuntimeAttr
#Stop signal can optionally be engaged by doing addStopSignal inside the action definition
outputs, response = executeContract(action, outputs, definition)
responses.append(response)
#Register responses in process registry
if action.kind == "action":
outputs["processes"][definition.name][action.name]["response"] = response