I'm getting a weird error when trying to run a flow using the DaskExecutor:

AttributeError: 'Edge' object has no attribute 'upstream_task'

I'm getting this when dask tries to use pickle to load the first of my mapped tasks. The first two tasks of the flow are not mapped, and they don't have issues. Any thoughts?

Are you able to share the Flow?

Definitely upstream_task, here's the screenshot:

Ah ok i’ll need to see code I think

Does a serialized flow work? I couldn't provide code if I wanted to, this one is generated at registration time based on specifications stored in yaml files. But I can output the serialized flow to a file if that works

More like I need to read the code to figure out what happened so if you have a dummy example that can reproduce it, that would work

oh gotcha. i'll have to play around and see if i can make a simple example that causes the error. since I don't know what is causing it I'm not sure how to do that. I'll follow up once I determine if I can get an example or not