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