gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1445

Browse Source 
Refactor gather_read_tags function to accept a logger parameter and replace print statements with structured logging for improved traceability.
This commit is contained in:
vitor-aignosi
2025-12-18 11:32:05 -03:00
parent 4a672745c5
commit 97792e36e5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
orchestrator/utils/orchestrator_functions.py
View File

@@ -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