From 8e3d62ff76954f08750982cf7f13e805b1327739 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Thu, 23 Oct 2025 15:17:47 -0300 Subject: [PATCH] SIENTIAPDE-1314 Refactor IngestorManager to streamline server disconnection process - Simplified the logic in the `update_opc_servers` method by directly appending servers to the disconnection list and utilizing the new `remove_server` method for handling server shutdowns. - Removed redundant code related to managing the `managed_tags` during server disconnection, enhancing code clarity and maintainability. --- ingestor/managers/ingestor_manager.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/ingestor/managers/ingestor_manager.py b/ingestor/managers/ingestor_manager.py index c63039c..fc0a534 100644 --- a/ingestor/managers/ingestor_manager.py +++ b/ingestor/managers/ingestor_manager.py @@ -289,14 +289,10 @@ class IngestorManager(BaseActivity): if is_lost: self.logger.warning(f'OPC server {server} is lost. Server will be disconnected.') - for slot, _config in self.managed_tags.items(): - to_disconnect.append(server) - self.managed_tags[slot].pop(server, None) + to_disconnect.append(server) for server in to_disconnect: - if server in self.opc_managers: - await self.opc_managers[server].shutdown() - del self.opc_managers[server] + await self.remove_server(server) metrics.OPC_MANAGERS_ACTIVE.labels(pod_id=self.pod_id).set(len(self.opc_managers))