From 1eb57113456a38b5043d1335a38a394f28f9d739 Mon Sep 17 00:00:00 2001 From: Matheus Date: Wed, 3 Sep 2025 11:47:47 -0300 Subject: [PATCH] =?UTF-8?q?Atualiza=20o=20OPC=20Manager=20para=20incluir?= =?UTF-8?q?=20um=20intervalo=20de=20watchdog=20de=201=20hora=20e=20define?= =?UTF-8?q?=20o=20nome=20do=20cliente=20como=20o=20ID=20do=20pod.=20Ajusta?= =?UTF-8?q?=20os=20testes=20para=20refletir=20essas=20mudan=C3=A7as=20na?= =?UTF-8?q?=20inicializa=C3=A7=C3=A3o=20do=20cliente.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ingestor/managers/opc_manager.py | 3 ++- tests/unit/managers/test_opc_manager.py | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) 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()