bpo-44176: Allow asyncio.as_completed()'s first parameter to be a generator yielding awaitables

Lib/asyncio/tasks.py

@@ -362,7 +362,7 @@ async def wait(fs, *, timeout=None, return_when=ALL_COMPLETED):
     Note: This does not raise TimeoutError! Futures that aren't done
     when the timeout occurs are returned in the second set.
     """
-    if futures.isfuture(fs) or coroutines.iscoroutine(fs):
+    if futures.isfuture(fs) or inspect.isawaitable(fs):
         raise TypeError(f"expect a list of futures, not {type(fs).__name__}")
     if not fs:
         raise ValueError('Set of coroutines/Futures is empty.')
@@ -543,7 +543,7 @@ def as_completed(fs, *, timeout=None):
 
     Note: The futures 'f' are not necessarily members of fs.
     """
-    if futures.isfuture(fs) or coroutines.iscoroutine(fs):
+    if futures.isfuture(fs) or inspect.isawaitable(fs):
         raise TypeError(f"expect an iterable of futures, not {type(fs).__name__}")
 
     from .queues import Queue  # Import here to avoid circular import problem.

Misc/NEWS.d/next/Library/2021-06-02-03-12-44.bpo-44176.-9OGEL.rst

@@ -0,0 +1 @@
+Use ``inspect.isawaitable()`` to detect if ``as_completed()``'s first parameter is awaitable