summaryrefslogtreecommitdiffstats
path: root/Lib/test/test_asyncio/test_queues.py
diff options
context:
space:
mode:
authorYurii Karabas <1998uriyyo@gmail.com>2020-11-28 08:21:17 (GMT)
committerGitHub <noreply@github.com>2020-11-28 08:21:17 (GMT)
commite4fe303b8cca525e97d44e80c7e53bdab9dd9187 (patch)
tree746867bfba9e64e9bbf94d98a910edb06c589890 /Lib/test/test_asyncio/test_queues.py
parentf9195318a863e237f41ed7665c767028cde1c9a3 (diff)
downloadcpython-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.py8
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():