From: Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com>
Date: Tue, 7 Mar 2023 03:14:55 +0000 (+0530)
Subject: Remove redundant `_ensure_future` in favor of `ensure_future` in `asyncio` (#102398)
X-Git-Tag: v3.12.0a6~4
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=d8485d6c8bd7ad8191fde337d81c01f2192855eb;p=thirdparty%2FPython%2Fcpython.git

Remove redundant `_ensure_future` in favor of `ensure_future` in `asyncio` (#102398)
---

diff --git a/Lib/asyncio/tasks.py b/Lib/asyncio/tasks.py
index a2e06d5ef72f..1c20754b839b 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