Task was destroyed but it is pending for each request

Question

I am starting a new loop in each requests and I am getting below error when i manually kill my service.

ERROR:asyncio:Task was destroyed but it is pending!
task:  wait_for=>

Here is my code:

loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
c = doSomething( maxtasks=100)
loop.run_until_complete(c.run())
try:
loop.stop()
loop.close()
print('done:')
except RuntimeError:
print('errr:')

I have also tried to get all the pending tasking before closing the loop using below code so that I can close all the tasks before closing but I am getting "RuntimeError: no running event loop"

pending = asyncio.all_tasks()

Can anybody tell me how do I kill all these tasks after my loop ends. I dont want these loops to run in background and take my whole memory

user_488944 · Answer

Assuming you are using caio in doSomething(). This worked for me with caio:

loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
context = caio.AsyncioContext(16, loop=loop)
loop.run_until_complete(main(context))
context.close()

Task was destroyed but it is pending for each request

1 Answers