SIENTIAPDE-1049
Stability fix try
This commit is contained in:
@@ -131,6 +131,13 @@ class IngestorManager():
|
|||||||
|
|
||||||
if server_instance is not None:
|
if server_instance is not None:
|
||||||
self.opc_managers[server] = server_instance
|
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()):
|
for server in list(self.opc_managers.keys()):
|
||||||
if server not in registered_servers:
|
if server not in registered_servers:
|
||||||
@@ -168,13 +175,6 @@ class IngestorManager():
|
|||||||
self.manage_server(
|
self.manage_server(
|
||||||
slot, server, slot_config[server], slot_config[server]['tags']
|
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):
|
def declare_active(self):
|
||||||
"""
|
"""
|
||||||
|
|||||||
Reference in New Issue
Block a user