Merge pull request #19 from Aignosi/OPC-connection-changes
Atualiza o OPC Manager para incluir um intervalo de watchdog de 1 hor…
This commit is contained in:
@@ -175,7 +175,8 @@ class OpcManager(BaseActivity):
|
||||
metrics.OPC_CONNECTIONS_TOTAL.labels(
|
||||
pod_id=self.pod_id, server_name=self.name).inc()
|
||||
try:
|
||||
self.client = Client(self.url)
|
||||
self.client = Client(self.url, watchdog_intervall=3600000)
|
||||
self.client.name = self.pod_id
|
||||
if self.cert_path:
|
||||
await self.set_security()
|
||||
self.logger.info(f'Starting connection to {self.name}...')
|
||||
|
||||
@@ -146,7 +146,7 @@ async def test_connect_no_security(client, mock_metrics, raw_opc_manager):
|
||||
|
||||
await raw_opc_manager.connect()
|
||||
|
||||
client.assert_called_once_with(raw_opc_manager.url)
|
||||
client.assert_called_once_with(raw_opc_manager.url, watchdog_intervall=3600000)
|
||||
raw_opc_manager.client.connect.assert_called_once()
|
||||
raw_opc_manager.set_security.assert_not_called()
|
||||
mock_metrics.OPC_CONNECTIONS_TOTAL.labels.assert_called_once_with(
|
||||
@@ -175,7 +175,7 @@ async def test_connect_with_security(client, raw_opc_manager):
|
||||
|
||||
await raw_opc_manager.connect()
|
||||
|
||||
client.assert_called_once_with(raw_opc_manager.url)
|
||||
client.assert_called_once_with(raw_opc_manager.url, watchdog_intervall=3600000)
|
||||
raw_opc_manager.client.connect.assert_called_once()
|
||||
raw_opc_manager.set_security.assert_called_once()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user