python 3.6 and ValueError: loop argument must agree with Future

Question

I just want to run a simple test example yet I get the below error. How do I resolve?

import asyncio import uvloop import concurrent.futures import time asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) async def do_some_work(x): while True: print("Waiting " + str(x)) await asyncio.sleep(x) if __name__ == '__main__': loop = asyncio.new_event_loop() tasks = [asyncio.ensure_future(do_some_work(2)), asyncio.ensure_future(do_some_work(5))] loop.run_until_complete(asyncio.gather(*tasks)) Traceback (most recent call last): File "/Users/worker_why.py", line 23, in <module> loop.run_until_complete(asyncio.gather(*tasks)) File "uvloop/loop.pyx", line 1181, in uvloop.loop.Loop.run_until_complete (uvloop/loop.c:25184) File "/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/tasks.py", line 508, in ensure_future raise ValueError('loop argument must agree with Future') ValueError: loop argument must agree with Future

Have you tried passing newly created loop to ensure_future? asyncio.ensure_future(..., loop=loop) — vaultah
– vaultah, Commented Oct 18, 2017 at 8:50

Mikhail Gerasimov · Accepted Answer · 2017-10-18 10:54:20Z

loop = asyncio.new_event_loop()

If you create new event loop and don't want to pass it everywhere, you should also make this loop current for context:

loop = asyncio.new_event_loop() asyncio.set_event_loop(loop)

Collectives™ on Stack Overflow

python 3.6 and ValueError: loop argument must agree with Future

1 Answer 1

Comments

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Related