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 3a41a12 commit cd3e071Copy full SHA for cd3e071
packages/service-library/src/servicelib/redis/_client.py
@@ -79,9 +79,7 @@ async def _periodic_check_health() -> None:
79
async def shutdown(self) -> None:
80
if self._health_check_task:
81
assert self._health_check_task_started_event # nosec
82
- await (
83
- self._health_check_task_started_event.wait()
84
- ) # NOTE: wait for the health check task to start
+ await self._health_check_task_started_event.wait() # NOTE: wait for the health check task to have started once before we can cancel it
85
await cancel_wait_task(self._health_check_task)
86
87
await self._client.aclose(close_connection_pool=True)
packages/service-library/tests/redis/test_client_reconection.py
0 commit comments