From dfda7245da6c9217a740b7624e25474c8a84aba1 Mon Sep 17 00:00:00 2001 From: bonnal-enzo Date: Sat, 30 Dec 2023 16:44:33 +0100 Subject: [PATCH] lint --- streamable/_execution/_concurrency.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streamable/_execution/_concurrency.py b/streamable/_execution/_concurrency.py index ac13bc8..007bdf5 100644 --- 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