Hello does Prefect support asynchronous tasks

Question

Kevin Kho · Answer

Hey < Daniil Ponizov> I think is a good answer

Zach Angell · Answer

We are also working on features to support asynchronous tasks slightly smiling face

Daniil Ponizov · Answer

how can i get event loop inside task run

Kevin Kho · Answer

How would you do it without Prefect `get event loop `

Daniil Ponizov · Answer

you mean use it like this ``` task def some task loop = asyncio get event loop loop run until complete asyncio wait futures with Flow flow name as fl some task ```

Daniil Ponizov · Answer

sorry cant format this snippet

Daniil Ponizov · Answer

when i try to hide event loop in task it doesn t see any coroutine and just finish

Kevin Kho · Answer

Let me ask the team if anyone if familiar with async

emre · Answer

Hey < Daniil Ponizov> I tried a couple things and had success with the following snippet ``` task def async sleeper i loop = asyncio new event loop tasks = loop create task some coro for in range i loop run until complete asyncio wait tasks ``` I don t know what is happening But using `loop create task` instead of `asyncio create task` did the trick for me I can execute this task in a mapped fashion even `DaskExecutor` works with the above setup but `LocalDaskExecutor` does not

emre · Answer

I recommend using `asyncio new event loop` instead of the usual `get event loop` event loops are single threaded by default python gets confused when multiple threads try to access the single event loop owned by the python process Instead create a fresh event loop at the start of your tasks with `new event loop` Also its probably best if you close the loop when the task finishes