From 89ac81e5e543b1cc234029007c5159f41b8dae94 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Tue, 10 Jun 2025 08:32:16 -0300 Subject: [PATCH] SIENTIAPDE-1095 Fix read_tags access in gather_read_tags function and update samples.json to use write_tags --- orchestrator/utils/orchestrator_functions.py | 2 +- samples.json | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/orchestrator/utils/orchestrator_functions.py b/orchestrator/utils/orchestrator_functions.py index 6d18011..5375e14 100644 --- a/orchestrator/utils/orchestrator_functions.py +++ b/orchestrator/utils/orchestrator_functions.py @@ -128,7 +128,7 @@ def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]: # Get all read tags from pipelines for pipeline in pipelines: - for tag in pipeline['read_tags']: + for tag in pipeline.get('read_tags', []): tag_string = f"{tag['server_id']}:{tag['tag_address']}" if tag_string not in tags: tags[tag_string] = { diff --git a/samples.json b/samples.json index 336ef01..18c7177 100644 --- a/samples.json +++ b/samples.json @@ -66,7 +66,7 @@ "max_retry_policy": 1, "query": "select * from sientia_data.laborious_data order by \"timestamp\" desc limit 30;", "retention_time": 60, - "opc_output_config": [ + "write_tags": [ { "server_id": "1", "type": "prediction",