Added rich progress bars

core/execution/operation/operation.py

@@ -1,27 +1,23 @@
 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(
             actions,
@@ -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

requirements.txt

@@ -1 +1,2 @@
 requests
+rich