From e456902a1dd43f259ca6a3c8a689f4b2fbb5f79f Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Wed, 28 Oct 2026 16:42:59 -0400 Subject: [PATCH] Updated bypassed defnition --- core/execution/operation/operation.py | 6 ++++-- core/execution/recursive.py | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) 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")