From 5da12a10bb7cb05d4aff8f56ca22348806ce4740 Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Wed, 28 Oct 2026 11:18:23 -0400 Subject: [PATCH] Added rich progress bars --- core/execution/operation/operation.py | 33 +++++++++++++-------------- requirements.txt | 1 + 2 files changed, 17 insertions(+), 17 deletions(-) diff --git a/core/execution/operation/operation.py b/core/execution/operation/operation.py index ae709e4..6b1e746 100644 --- a/core/execution/operation/operation.py +++ b/core/execution/operation/operation.py @@ -1,26 +1,22 @@ import logging import pprint +from rich.progress import track + from core.runtime.managefailure import manageFailure from core.runtime.stopsignals import checkDependency from core.execution.processregistry import registerProcess -#from tqdm import tqdm -from rich.progress import track + outputs = {} def buildOperation(definition, outputs): + process_log = True + from core.execution.executioncontract import executeContract actions = definition.actions outputs = registerProcess(definition, outputs) responses = [] - - #for action in tqdm( - # actions, - # desc=definition.name, - # unit="action" - #): - if getattr(definition, "track", False): actions = track( @@ -52,19 +48,22 @@ def buildOperation(definition, outputs): if action.kind == "action": outputs["processes"][definition.name][action.name]["response"] = response - #Print completion status after runtime processes - print(f"{action.name} completed") - ##Append completed process to process registry outputs["processes"][definition.name]["completed"].append(action.alias) - #For debugging purposes only - process_registry_logs = False - if process_registry_logs: - pprint.pprint(outputs["processes"]) - #Temporarily disabled manageFailure functions #except Exception as error: #outputs = manageFailure(error, action, outputs) + + #Print completion status after runtime processes + if process_log: + logging.info(f"{definition.name} completed") + + #For debugging purposes only + process_registry_logs = False + if process_registry_logs: + pprint.pprint(outputs["processes"]) + + return outputs, responses diff --git a/requirements.txt b/requirements.txt index f229360..195624e 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1 +1,2 @@ requests +rich \ No newline at end of file