From 950707386a76c5dc7d452489e8fb32d41b8e24ac Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Wed, 28 Oct 2026 17:44:09 -0400 Subject: [PATCH] Stopped returning outputs for registerProcess --- core/execution/operation/operation.py | 9 +-------- core/execution/processregistry.py | 2 +- core/execution/recursive.py | 2 +- 3 files changed, 3 insertions(+), 10 deletions(-) diff --git a/core/execution/operation/operation.py b/core/execution/operation/operation.py index 326cd8f..e396c8d 100644 --- a/core/execution/operation/operation.py +++ b/core/execution/operation/operation.py @@ -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 diff --git a/core/execution/processregistry.py b/core/execution/processregistry.py index 3319885..4558654 100644 --- a/core/execution/processregistry.py +++ b/core/execution/processregistry.py @@ -9,4 +9,4 @@ def registerProcess(module, outputs): outputs["processes"][module.name]["stopsignals"] = [] outputs["processes"][module.name]["completed"] = [] - return outputs \ No newline at end of file + return \ No newline at end of file diff --git a/core/execution/recursive.py b/core/execution/recursive.py index 2be7ca8..827a3f4 100644 --- a/core/execution/recursive.py +++ b/core/execution/recursive.py @@ -19,7 +19,7 @@ def buildRecursive(definition, outputs): logging.debug(f"No items available in {source} for {definition.name}") return outputs, [] - outputs = registerProcess(definition, outputs) + registerProcess(definition, outputs) responses = [] from core.execution.executioncontract import executeContract