Skip to content

Commit

Permalink
fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Dan King committed Oct 25, 2023
1 parent 48c7aa1 commit b0e5ce5
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions hail/python/hailtop/batch/batch_pool_executor.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from typing import Optional, Callable, Type, Union, List, Any, Iterable
from typing import Optional, Callable, Type, Union, List, Any, Iterable, AsyncGenerator
from types import TracebackType
from io import BytesIO
import warnings
Expand Down Expand Up @@ -225,10 +225,11 @@ async def async_map(self,
fn: Callable,
iterables: Iterable[Iterable[Any]],
timeout: Optional[Union[int, float]] = None,
chunksize: int = 1):
chunksize: int = 1
) -> AsyncGenerator[Any, None]:
"""Aysncio compatible version of :meth:`.map`."""
if not iterables:
return iter([])
return (x for x in range(0))

if chunksize > 1:
list_per_argument = [list(x) for x in iterables]
Expand Down

0 comments on commit b0e5ce5

Please sign in to comment.