From 2fa1d2175e68152163aecbe86a9390bb0c20611f Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Tue, 20 May 2025 11:04:41 -0300 Subject: [PATCH] SIENTIAPDE-1049 Stability fix try --- ingestor/managers/ingestor_manager.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/ingestor/managers/ingestor_manager.py b/ingestor/managers/ingestor_manager.py index 42657d7..78b442f 100644 --- a/ingestor/managers/ingestor_manager.py +++ b/ingestor/managers/ingestor_manager.py @@ -131,6 +131,13 @@ class IngestorManager(): if server_instance is not None: self.opc_managers[server] = server_instance + else: + self.logger.warning( + f"Failed to initialize OPC manager for server {server}, " + f"removing server from managed tags." + ) + _a = [self.managed_tags[slot].pop(server, None) + for slot, _value in self.managed_tags.items()] for server in list(self.opc_managers.keys()): if server not in registered_servers: @@ -168,13 +175,6 @@ class IngestorManager(): self.manage_server( slot, server, slot_config[server], slot_config[server]['tags'] ) - else: - self.logger.warning( - f"OPC server {server} reconnecting failed. " - f"Removing server from managed tags." - ) - for slot, slot_config in self.managed_tags.items(): - self.managed_tags[slot].pop(server, None) def declare_active(self): """