diff --git a/taskiq/task.py b/taskiq/task.py index b4a0f52..550dabe 100644 --- a/taskiq/task.py +++ b/taskiq/task.py @@ -98,9 +98,9 @@ async def wait_result( """ start_time = time() while not await self.is_ready(): - await asyncio.sleep(check_interval) if 0 < timeout < time() - start_time: raise TaskiqResultTimeoutError(timeout=timeout) + await asyncio.sleep(check_interval) return await self.get_result(with_logs=with_logs) async def get_progress(self) -> "TaskProgress[Any] | None":