We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 88c77bd commit 1cc94e7Copy full SHA for 1cc94e7
services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/service_tracker/_tracker.py
@@ -34,7 +34,12 @@ async def delete(self, node_id: NodeID) -> None:
34
await self.redis_client_sdk.redis.delete(_get_key(node_id))
35
36
async def all(self) -> dict[NodeID, TrackedServiceModel]:
37
- found_keys = await self.redis_client_sdk.redis.keys(f"{_KEY_PREFIX}*")
+ found_keys = [
38
+ x
39
+ async for x in self.redis_client_sdk.redis.scan_iter(
40
+ match=f"{_KEY_PREFIX}*"
41
+ )
42
+ ]
43
found_values = await self.redis_client_sdk.redis.mget(found_keys)
44
45
return {
0 commit comments