SIENTIAPDE-1110
Update OPC_URL in values.yaml and enhance input data logging in PredictionProcess for improved traceability.
This commit is contained in:
@@ -57,14 +57,18 @@ class PredictionProcess():
|
|||||||
start_to_close_timeout=timedelta(minutes=1),
|
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(
|
path_flag, confidence, comment = await workflow.execute_local_activity_method(
|
||||||
Activities.input_gate,
|
Activities.input_gate,
|
||||||
{
|
gate_input,
|
||||||
**metadata,
|
|
||||||
'filters': input_data['input_filters'],
|
|
||||||
'data': data,
|
|
||||||
'path_priority': input_data['path_priority']
|
|
||||||
},
|
|
||||||
retry_policy=retry_policy,
|
retry_policy=retry_policy,
|
||||||
start_to_close_timeout=timedelta(minutes=1),
|
start_to_close_timeout=timedelta(minutes=1),
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -155,7 +155,7 @@ env:
|
|||||||
- name: OPC_ID
|
- name: OPC_ID
|
||||||
value: "server-1"
|
value: "server-1"
|
||||||
- name: OPC_URL
|
- 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
|
- name: KAFKA_BOOTSTRAP_SERVERS
|
||||||
value: "kafka.kafka.svc.cluster.local:9092"
|
value: "kafka.kafka.svc.cluster.local:9092"
|
||||||
|
|||||||
Reference in New Issue
Block a user