SIENTIAPDE-1049
Integrity fix
This commit is contained in:
@@ -169,6 +169,10 @@ class IngestorManager():
|
||||
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)
|
||||
|
||||
@@ -301,6 +305,8 @@ class IngestorManager():
|
||||
for slot, slot_config in self.managed_tags.items():
|
||||
self.resource_manager.renew_tag_lease(slot)
|
||||
update = self.resource_manager.get_tag_slot(slot)
|
||||
self.logger.debug(
|
||||
f"Comparing slot {slot} configuration: {slot_config} with update: {update}")
|
||||
if update is None:
|
||||
self.logger.warning(
|
||||
f"Slot {slot} configuration not found. "
|
||||
|
||||
Reference in New Issue
Block a user