diff options
author | Yurii Karabas <1998uriyyo@gmail.com> | 2020-11-28 08:21:17 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-11-28 08:21:17 (GMT) |
commit | e4fe303b8cca525e97d44e80c7e53bdab9dd9187 (patch) | |
tree | 746867bfba9e64e9bbf94d98a910edb06c589890 /Lib/test/test_asyncio/test_queues.py | |
parent | f9195318a863e237f41ed7665c767028cde1c9a3 (diff) | |
download | cpython-e4fe303b8cca525e97d44e80c7e53bdab9dd9187.zip cpython-e4fe303b8cca525e97d44e80c7e53bdab9dd9187.tar.gz cpython-e4fe303b8cca525e97d44e80c7e53bdab9dd9187.tar.bz2 |
bpo-42392: Remove loop parameter from asyncio.tasks and asyncio.subprocess (GH-23521)
Diffstat (limited to 'Lib/test/test_asyncio/test_queues.py')
-rw-r--r-- | Lib/test/test_asyncio/test_queues.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/Lib/test/test_asyncio/test_queues.py b/Lib/test/test_asyncio/test_queues.py index dc97673..0a0b529 100644 --- a/Lib/test/test_asyncio/test_queues.py +++ b/Lib/test/test_asyncio/test_queues.py @@ -255,6 +255,7 @@ class QueueGetTests(_QueueTestBase): def test_why_are_getters_waiting(self): # From issue #268. + asyncio.set_event_loop(self.loop) async def consumer(queue, num_expected): for _ in range(num_expected): @@ -276,8 +277,7 @@ class QueueGetTests(_QueueTestBase): self.loop.run_until_complete( asyncio.gather(producer(q, producer_num_items), - consumer(q, producer_num_items), - loop=self.loop), + consumer(q, producer_num_items)), ) def test_cancelled_getters_not_being_held_in_self_getters(self): @@ -498,6 +498,7 @@ class QueuePutTests(_QueueTestBase): def test_why_are_putters_waiting(self): # From issue #265. + asyncio.set_event_loop(self.loop) async def create_queue(): q = asyncio.Queue(2) @@ -519,8 +520,7 @@ class QueuePutTests(_QueueTestBase): t1 = putter(1) t2 = putter(2) t3 = putter(3) - self.loop.run_until_complete( - asyncio.gather(getter(), t0, t1, t2, t3, loop=self.loop)) + self.loop.run_until_complete(asyncio.gather(getter(), t0, t1, t2, t3)) def test_cancelled_puts_not_being_held_in_self_putters(self): def a_generator(): |