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

SIENTIAPDE-1095

Browse Source 
Fix read_tags access in gather_read_tags function and update samples.json to use write_tags
This commit is contained in:
vitor-aignosi
2025-06-10 08:32:16 -03:00
parent caa7b125f9
commit 89ac81e5e5
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
orchestrator/utils/orchestrator_functions.py
View File

@@ -128,7 +128,7 @@ def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]:
# Get all read tags from pipelines # Get all read tags from pipelines
for pipeline in 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']}" tag_string = f"{tag['server_id']}:{tag['tag_address']}"
if tag_string not in tags: if tag_string not in tags:
tags[tag_string] = { tags[tag_string] = {

2
samples.json
View File

@@ -66,7 +66,7 @@
"max_retry_policy": 1, "max_retry_policy": 1,
"query": "select * from sientia_data.laborious_data order by \"timestamp\" desc limit 30;", "query": "select * from sientia_data.laborious_data order by \"timestamp\" desc limit 30;",
"retention_time": 60, "retention_time": 60,
"opc_output_config": [ "write_tags": [
{ {
"server_id": "1", "server_id": "1",
"type": "prediction", "type": "prediction",