From 2870219558eba983813aeab249e08371266ab524 Mon Sep 17 00:00:00 2001
From: jack1142 <6032823+jack1142@users.noreply.github.com>
Date: Tue, 31 Mar 2020 02:37:38 +0200
Subject: [PATCH] Stop using `loop` kwarg in `asyncio.wait()` call
(DeprecationWarning) (#327)
---
uvloop/handles/process.pyx | 2 +-
uvloop/loop.pyx | 7 +++----
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/uvloop/handles/process.pyx b/uvloop/handles/process.pyx
index 13360d5..f2e0f58 100644
--- a/uvloop/handles/process.pyx
+++ b/uvloop/handles/process.pyx
@@ -604,7 +604,7 @@ cdef class UVProcessTransport(UVProcess):
if handle._init_futs:
handle._stdio_ready = 0
- init_fut = aio_gather(*handle._init_futs, loop=loop)
+ init_fut = aio_gather(*handle._init_futs)
init_fut.add_done_callback(
ft_partial(handle.__stdio_inited, waiter))
else:
diff --git a/uvloop/loop.pyx b/uvloop/loop.pyx
index c865fed..a368c52 100644
--- a/uvloop/loop.pyx
+++ b/uvloop/loop.pyx
@@ -1682,7 +1682,7 @@ cdef class Loop:
uv.SOCK_STREAM, 0, flags,
0) for host in hosts]
- infos = await aio_gather(*fs, loop=self)
+ infos = await aio_gather(*fs)
completed = False
sock = None
@@ -1908,7 +1908,7 @@ cdef class Loop:
lai = &lai_static
if len(fs):
- await aio_wait(fs, loop=self)
+ await aio_wait(fs)
if rai is NULL:
ai_remote = f1.result()
@@ -3095,8 +3095,7 @@ cdef class Loop:
shutdown_coro = aio_gather(
*[ag.aclose() for ag in closing_agens],
- return_exceptions=True,
- loop=self)
+ return_exceptions=True)
results = await shutdown_coro
for result, agen in zip(results, closing_agens):