Hello, is there a way to have the prefect agent execute a flow in a single threaded manor? I converted an existing ml model training script that makes use of some datatypes that cannot be pickled. Returning these types from tasks works fine when executing the flow locally in a single thread but using the DaskExecutor or running the flow on the agent causes the flow to fail.

Hey @Austin Mackillop, you can explicitly specify LocalExecutor, which is the default (or maybe even LocalDaskExecutor). I’ve seen this some for some people. What

Storage

are ytou using?

I tried specifying the executor like so:

with Flow("train-model", executor=LocalExecutor()) as flow:

But on the Ui it still appears to be doing things in parallel. I’m using whatever the default storage is.

Could you run your flow with debug level logs and see the executor that shows when the flow starts?

How do I do that with the local agent?

One sec let me try

I changed my tasks such that none of them returned un serializable objects and that solved my problem

Glad you got it working @Austin Mackillop!