From 1325e7b7e3dcccdb38e5bb63dd7578498798ffb6 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Fri, 27 Jun 2025 10:00:34 -0300 Subject: [PATCH] SIENTIAPDE-1110 Update OPC_URL in values.yaml and enhance input data logging in PredictionProcess for improved traceability. --- .../sub_workflows/prediction_process.py | 16 ++++++++++------ values.yaml | 2 +- 2 files changed, 11 insertions(+), 7 deletions(-) diff --git a/laborious/workflows/sub_workflows/prediction_process.py b/laborious/workflows/sub_workflows/prediction_process.py index 3d5bef8..3ce22ff 100644 --- a/laborious/workflows/sub_workflows/prediction_process.py +++ b/laborious/workflows/sub_workflows/prediction_process.py @@ -57,14 +57,18 @@ class PredictionProcess(): start_to_close_timeout=timedelta(minutes=1), ) + gate_input = { + **metadata, + 'filters': input_data['input_filters'], + 'data': data, + 'path_priority': input_data['path_priority'] + } + + print(f"Metadata e input atualizadas {gate_input}") + path_flag, confidence, comment = await workflow.execute_local_activity_method( Activities.input_gate, - { - **metadata, - 'filters': input_data['input_filters'], - 'data': data, - 'path_priority': input_data['path_priority'] - }, + gate_input, retry_policy=retry_policy, start_to_close_timeout=timedelta(minutes=1), ) diff --git a/values.yaml b/values.yaml index 7b657e4..5ac7e4b 100644 --- a/values.yaml +++ b/values.yaml @@ -155,7 +155,7 @@ env: - name: OPC_ID value: "server-1" - name: OPC_URL - value: "opc.tcp://sientia-opc-simulator.sientia.svc.cluster.local:4840" + value: "opc.tcp://sientia-opc-simulator-opc.sientia.svc.cluster.local:4840" - name: KAFKA_BOOTSTRAP_SERVERS value: "kafka.kafka.svc.cluster.local:9092"