diff options
author | Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com> | 2023-03-07 08:44:55 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-03-07 08:44:55 +0530 |
commit | d8485d6c8bd7ad8191fde337d81c01f2192855eb (patch) | |
tree | 49256b3d35dac56a702c4142c5c9f45b414ab4b8 | |
parent | gh-95913: Edit Faster CPython section in 3.11 WhatsNew (GH-98429) (diff) | |
download | cpython-d8485d6c8bd7ad8191fde337d81c01f2192855eb.tar.gz cpython-d8485d6c8bd7ad8191fde337d81c01f2192855eb.tar.bz2 cpython-d8485d6c8bd7ad8191fde337d81c01f2192855eb.zip |
Remove redundant `_ensure_future` in favor of `ensure_future` in `asyncio` (#102398)
-rw-r--r-- | Lib/asyncio/tasks.py | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/Lib/asyncio/tasks.py b/Lib/asyncio/tasks.py index a2e06d5ef72..1c20754b839 100644 --- a/Lib/asyncio/tasks.py +++ b/Lib/asyncio/tasks.py @@ -630,10 +630,6 @@ def ensure_future(coro_or_future, *, loop=None): If the argument is a Future, it is returned directly. """ - return _ensure_future(coro_or_future, loop=loop) - - -def _ensure_future(coro_or_future, *, loop=None): if futures.isfuture(coro_or_future): if loop is not None and loop is not futures._get_loop(coro_or_future): raise ValueError('The future belongs to a different loop than ' @@ -798,7 +794,7 @@ def gather(*coros_or_futures, return_exceptions=False): outer = None # bpo-46672 for arg in coros_or_futures: if arg not in arg_to_fut: - fut = _ensure_future(arg, loop=loop) + fut = ensure_future(arg, loop=loop) if loop is None: loop = futures._get_loop(fut) if fut is not arg: @@ -855,7 +851,7 @@ def shield(arg): weak references to tasks. A task that isn't referenced elsewhere may get garbage collected at any time, even before it's done. """ - inner = _ensure_future(arg) + inner = ensure_future(arg) if inner.done(): # Shortcut. return inner |