Compare commits
3 Commits
dba5300379
...
d83917a30f
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d83917a30f | ||
| 54c854bb0a | |||
|
|
06caa88ed8 |
@@ -561,8 +561,9 @@ class IngestorManager(SientiaMonitoring):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
# list() snapshots the readers: the loop awaits, so a reader added or removed
|
# list() snapshots the readers: the loop awaits, so a reader added or removed
|
||||||
# meanwhile must not break the iteration.
|
# meanwhile must not break the iteration. SonarQube flags it as an unnecessary
|
||||||
for server, reader in list(self.opc_managers.items()): # NOSONAR
|
# list() (S7504); the issue is accepted in SonarQube for this reason.
|
||||||
|
for server, reader in list(self.opc_managers.items()):
|
||||||
if slot in reader.subscriptions:
|
if slot in reader.subscriptions:
|
||||||
await self._unsubscribe_reader(server, reader, slot)
|
await self._unsubscribe_reader(server, reader, slot)
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
|
|||||||
|
|
||||||
[project]
|
[project]
|
||||||
name = "ingestor"
|
name = "ingestor"
|
||||||
version = "2.1.0-rc1"
|
version = "2.2.0-rc1"
|
||||||
description = "Sientia DataOps Ingestor - OPC Tag Ingestor"
|
description = "Sientia DataOps Ingestor - OPC Tag Ingestor"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
requires-python = ">=3.11"
|
requires-python = ">=3.11"
|
||||||
|
|||||||
Reference in New Issue
Block a user