-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Replace asyncio
to anyio
#3012
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Replace asyncio
to anyio
#3012
Conversation
Docs Preview
|
def _enter_lock(self) -> anyio.Lock: | ||
return anyio.Lock() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
def _enter_lock(self) -> anyio.Lock: | |
return anyio.Lock() | |
def _enter_lock(self) -> anyio.Lock: | |
# We use a cached_property for this because it seems to work better with temporal... | |
return anyio.Lock() |
for i, c in enumerate(awaitables): | ||
tg.start_soon(run_and_store, c, i) | ||
|
||
return results |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we return a tuple?
|
||
else: | ||
# TODO(Marcelo): We need to replace this with `anyio.as_completed()` from | ||
# https://github.com/agronholm/anyio/pull/890. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You intend to vendor that function right? Because I don't think we should wait until that's released and then bump the requirement all the way to the latest -- that'd be annoying for users
No description provided.