Skip to content

Commit

Permalink
fix: disable temp fix (#130)
Browse files Browse the repository at this point in the history
  • Loading branch information
BobTheBuidler authored Feb 16, 2024
1 parent 71f4089 commit cccaac7
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions a_sync/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,10 @@ async def __aiter__(self) -> AsyncIterator[Tuple[K, V]]:
async for key, value in as_completed(self, aiter=True):
if key not in yielded:
yield _yield(key, value, "both")
def keys(self) -> KeysView[K]:
if self._loader and not self._loader.done():
raise exceptions.RuntimeError("the loader needs time to complete. bob will figure out a way to make this not impact sync users")
return super().keys()
#def keys(self) -> KeysView[K]:
# if self._loader and not self._loader.done():
# raise RuntimeError("the loader needs time to complete. bob will figure out a way to make this not impact sync users")
# return super().keys()
async def map(self, *iterables: AnyIterable[K], pop: bool = True, yields: Literal['keys', 'both'] = 'both') -> AsyncIterator[Tuple[K, V]]:
if self:
raise exceptions.MappingNotEmptyError
Expand Down

0 comments on commit cccaac7

Please sign in to comment.