From 97792e36e5719149d2066f876c41a0a68d6d7059 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Thu, 18 Dec 2025 11:32:05 -0300 Subject: [PATCH] SIENTIAPDE-1445 Refactor gather_read_tags function to accept a logger parameter and replace print statements with structured logging for improved traceability. --- orchestrator/utils/orchestrator_functions.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/orchestrator/utils/orchestrator_functions.py b/orchestrator/utils/orchestrator_functions.py index 395462f..50d76a7 100644 --- a/orchestrator/utils/orchestrator_functions.py +++ b/orchestrator/utils/orchestrator_functions.py @@ -386,7 +386,7 @@ def predictions_batch(config: dict[str, Any]): } -def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]: +def gather_read_tags(pipelines: list[dict[str, Any]], logger) -> dict[str, Any]: """ Gather all read tags from input pipelines. @@ -405,7 +405,8 @@ def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]: # Get all read tags from pipelines for pipeline in pipelines: - print("asdddddddddddddddddddddddddd", pipeline['workflow_type'], pipeline.get('read_tags', [])) + logger.info( + f'Processing pipeline: {pipeline["workflow_type"]}: {pipeline.get("read_tags", [])}') if pipeline['workflow_type'] != 'scouter': continue