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 1d2bf81 commit 3723208Copy full SHA for 3723208
packages/service-library/src/servicelib/redis/_clients_manager.py
@@ -1,3 +1,4 @@
1
+import asyncio
2
from dataclasses import dataclass, field
3
4
from settings_library.redis import RedisDatabase, RedisSettings
@@ -28,10 +29,10 @@ async def setup(self) -> None:
28
29
)
30
31
async def shutdown(self) -> None:
- # NOTE: somehow using logged_gather is not an option
32
- # doing so will make the shutdown procedure hang
33
- for client in self._client_sdks.values():
34
- await client.shutdown()
+ await asyncio.gather(
+ *[client.shutdown() for client in self._client_sdks.values()],
+ return_exceptions=True,
35
+ )
36
37
def client(self, database: RedisDatabase) -> RedisClientSDK:
38
return self._client_sdks[database]
0 commit comments