Hi a dumb question maybe. I'm trying to make my flow to run in parallel via

run_agent

but I can't make it work I tried to use

flow.executor = LocalDaskExecutor()
flow.run()

& it can run in parallel, but not

run_agent

. any clue?

Hi @Alvis Tang -- I wouldn't recommend using

run_agent

it's just going to be confusing. I'd recommend starting the agent in a separate process. Your flow script should have

flow.register()

and then you'd run the flow from the UI and run an agent in a separate process to kick off the flow run. Either way, using the dask executor should be giving you the parallelism you want.

Thx @Zanie Yes. I think it's less confusing to just use the cli to start the agent

You can pass additional arguments to the executor to specify the number of threads/processes

@Zanie Just checked the doc https://docs.prefect.io/api/latest/executors.html#localdaskexecutor

Yep the `**kwargs (Any)`: Additional keyword arguments to pass to dask config is what you'

thx @Zanie For the record, the argument is

LocalDaskExecutor(_num_workers_=n_workers)