diff --git a/ingestor/managers/opc_manager.py b/ingestor/managers/opc_manager.py index 2e8d4f4..b67fcf6 100644 --- a/ingestor/managers/opc_manager.py +++ b/ingestor/managers/opc_manager.py @@ -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}...') diff --git a/tests/unit/managers/test_opc_manager.py b/tests/unit/managers/test_opc_manager.py index 1dca619..cbabcc7 100644 --- a/tests/unit/managers/test_opc_manager.py +++ b/tests/unit/managers/test_opc_manager.py @@ -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()