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 3f99d97 commit 1717a94Copy full SHA for 1717a94
packages/service-library/src/servicelib/redis/_client.py
@@ -102,9 +102,10 @@ async def shutdown(self) -> None:
102
_logger, level=logging.DEBUG, msg=f"Shutdown RedisClientSDK {self}"
103
):
104
if self._health_check_task:
105
+ assert self._health_check_task_started_event # nosec
106
+ await self._health_check_task_started_event.wait()
107
+
108
with log_catch(_logger, reraise=False):
- assert self._health_check_task_started_event # nosec
- await self._health_check_task_started_event.wait()
109
await cancel_wait_task(
110
self._health_check_task, max_delay=_HEALTHCHECK_TASK_TIMEOUT_S
111
)
0 commit comments