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"