diff --git a/core/execution/operation/operation.py b/core/execution/operation/operation.py index 3d7fbdb..326cd8f 100644 --- a/core/execution/operation/operation.py +++ b/core/execution/operation/operation.py @@ -61,8 +61,10 @@ def buildOperation(definition, outputs): #Print completion status after runtime processes if process_log: - #print(outputs["processes"][definition.name]["completed"]) - if len(outputs["processes"][definition.name]["completed"]) == 1: + stopsignal_count = len(outputs["processes"][definition.name]["stopsignals"]) + completed_count = len(outputs["processes"][definition.name]["completed"]) + + if completed_count == 1 and stopsignal_count == 1: logging.info(f"{definition.name} bypassed") else: logging.info(f"{definition.name} completed") diff --git a/core/execution/recursive.py b/core/execution/recursive.py index 8a87151..2be7ca8 100644 --- a/core/execution/recursive.py +++ b/core/execution/recursive.py @@ -73,8 +73,10 @@ def buildRecursive(definition, outputs): outputs["processes"][definition.name]["completed"].append(job.alias) if process_log: - #print(outputs["processes"][definition.name]["completed"]) - if len(outputs["processes"][definition.name]["completed"]) == 1: + stopsignal_count = len(outputs["processes"][definition.name]["stopsignals"]) + completed_count = len(outputs["processes"][definition.name]["completed"]) + + if completed_count == 1 and stopsignal_count == 1: logging.info(f"{definition.name} bypassed") else: logging.info(f"{definition.name} completed")