From 11d9034b9076d50e3d7e70a98767046c2928811b Mon Sep 17 00:00:00 2001 From: jack1142 <6032823+jack1142@users.noreply.github.com> Date: Sat, 28 Mar 2020 17:33:20 +0100 Subject: [PATCH 1/3] Update loop.pyx --- uvloop/loop.pyx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/uvloop/loop.pyx b/uvloop/loop.pyx index c865fedf..3b6a3ad9 100644 --- a/uvloop/loop.pyx +++ b/uvloop/loop.pyx @@ -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() From eb0dc18d457b8af1216ef5e18fca1d5d77909ccc Mon Sep 17 00:00:00 2001 From: jack1142 <6032823+jack1142@users.noreply.github.com> Date: Sat, 28 Mar 2020 18:22:08 +0100 Subject: [PATCH 2/3] Remove `loop=` from aio_gather too --- uvloop/loop.pyx | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/uvloop/loop.pyx b/uvloop/loop.pyx index 3b6a3ad9..a368c523 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 @@ -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): From dd3fd5cf7f11430848fca2a21b5c45bf3cc42fcc Mon Sep 17 00:00:00 2001 From: jack1142 <6032823+jack1142@users.noreply.github.com> Date: Sat, 28 Mar 2020 18:22:51 +0100 Subject: [PATCH 3/3] Update process.pyx --- uvloop/handles/process.pyx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/uvloop/handles/process.pyx b/uvloop/handles/process.pyx index 13360d5d..f2e0f58b 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: