lint

ebonnal · Dec 30, 2023 · dfda724 · dfda724
1 parent 02ca202
commit dfda724
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streamable/_execution/_concurrency.py b/streamable/_execution/_concurrency.py
@@ -83,9 +83,9 @@ def __iter__(self) -> Iterator[Union[R, _ExceptionContainer]]:
 
 
 class ThreadedFlatteningIteratorWrapper(ThreadedMappingIteratorWrapper[T]):
-
     class ShufflingNextsIterator(Iterator[Callable[[], Union[T, _Skip]]]):
         _INIT_RETRY_BACKFOFF = 0.0005
+
         def __init__(self, iterables_iterator: Iterator[Iterable[T]], pool_size: int):
             self.iterables_iterator = iterables_iterator
             self.iterator_iterator_exhausted = False