Vishal Talasani
02/16/2021, 8:55 AMLocalDaskExecutor(scheduler="threads", num_workers=5)
but it seems like I still can only serially execute my flows. Does anyone here have experience with this? Thank you so much for the help!Greg Roche
02/16/2021, 9:20 AMVishal Talasani
02/16/2021, 9:54 AMGreg Roche
02/16/2021, 10:18 AMflow.visualize()
to see the generated DAG which Prefect will use to execute the run, this will show how Prefect associates the tasks with each other and which dependencies each task would need to wait for in order to run.Vishal Talasani
02/16/2021, 8:32 PMflow.executor = LocalDaskExecutor(scheduler='threads')
flow.run_config = LocalRun()
should I be setting another variable on my flow before registering? Or is there perhaps something I need to run at the agent level to make it so I can run a local dask executor? Thanks again for the help!Greg Roche
02/17/2021, 8:14 AM