From e6733da110bc9bf00b13b88aca72bb6b48f08ec7 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" Date: Mon, 6 Jan 2025 03:56:31 +0000 Subject: [PATCH] chore: `black .` --- a_sync/utils/iterators.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/a_sync/utils/iterators.py b/a_sync/utils/iterators.py index 580e1697..720c64a4 100644 --- a/a_sync/utils/iterators.py +++ b/a_sync/utils/iterators.py @@ -18,9 +18,7 @@ _logger_log = logger._log -async def exhaust_iterator( - iterator: AsyncIterator[T], *, queue: Optional[Queue] = None -) -> None: +async def exhaust_iterator(iterator: AsyncIterator[T], *, queue: Optional[Queue] = None) -> None: """ Asynchronously iterates over items from the given async iterator and optionally places them into a queue. @@ -42,13 +40,13 @@ async def exhaust_iterator( - :func:`as_yielded` """ done = 0 - + async def unblock_loop(): nonlocal done done += 1 if done % 1000 == 0: await sleep(0) - + if queue is None: async for thing in iterator: await unblock_loop()