gitea_admin/sientia-dataops-opc-ingestor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1314

Browse Source 
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.
This commit is contained in:
vitor-aignosi
2025-10-23 15:17:47 -03:00
parent 56023dfdf4
commit 8e3d62ff76
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ingestor/managers/ingestor_manager.py
View File

@@ -289,14 +289,10 @@ class IngestorManager(BaseActivity):
if is_lost: if is_lost:
self.logger.warning(f'OPC server {server} is lost. Server will be disconnected.') 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) to_disconnect.append(server)
self.managed_tags[slot].pop(server, None)
for server in to_disconnect: for server in to_disconnect:
if server in self.opc_managers: await self.remove_server(server)
await self.opc_managers[server].shutdown()
del self.opc_managers[server]
metrics.OPC_MANAGERS_ACTIVE.labels(pod_id=self.pod_id).set(len(self.opc_managers)) metrics.OPC_MANAGERS_ACTIVE.labels(pod_id=self.pod_id).set(len(self.opc_managers))