hi, i am new to prefect, i was able to run task in parallel using: flow.run(executor=LocalDaskExecutor()), but calling run() is blocking tell all tasks are finished, possible to call run in non-blocking way? so the run()-call returns immediately
k
Kevin Kho
05/27/2022, 1:37 PM
No it’s not because Prefect 1 has a
gather
call in the code to execute tasks immediately so they are synchronous
You don’t intend to move to Cloud?
t
Tarek
05/30/2022, 6:22 AM
thanks for the answer , if i move to cloud, what will be different then?
k
Kevin Kho
05/30/2022, 4:00 PM
The agent will make the new process and you can have concurrent flows. It won’t be blocking