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 remove logger parameter and associated logging statements, streamlining the function for improved clarity and focus on processing pipelines.
This commit is contained in:
vitor-aignosi
2025-12-18 11:34:31 -03:00
parent 97792e36e5
commit 381b585c7a
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
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]], logger) -> dict[str, Any]: def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]:
""" """
Gather all read tags from input pipelines. Gather all read tags from input pipelines.
@@ -405,8 +405,6 @@ def gather_read_tags(pipelines: list[dict[str, Any]], logger) -> dict[str, Any]:
# Get all read tags from pipelines # Get all read tags from pipelines
for pipeline in pipelines: for pipeline in pipelines:
logger.info(
f'Processing pipeline: {pipeline["workflow_type"]}: {pipeline.get("read_tags", [])}')
if pipeline['workflow_type'] != 'scouter': if pipeline['workflow_type'] != 'scouter':
continue continue