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): """