https://prefect.io logo
j

Jehan Abduljabbar

07/15/2022, 1:32 PM
Good morning, I've got this issue. I am using LocalDaskExecuter() and Git Storage. When I run the flow in the cloud, dask breaks down a task into multiple ones, with new labels. But the flow in Git storage doesn't recognize the new tasks, which gives me a mismatch error between the flow version stored in prefect backend and the flow version in storage. How do I get around that?
1
a

Anna Geller

07/15/2022, 1:34 PM
to get around that, you would need to commit and push your code to GitHub and then possibly reregister your flow if any metadata changed since then
j

Jehan Abduljabbar

07/15/2022, 1:55 PM
But it is changing as the flow run is taking place in the cloud.
a

Anna Geller

07/15/2022, 2:35 PM
you have to commit your code and push it to your GitHub storage then, Prefect can grab the latest version of your flow at runtime
j

Jehan Abduljabbar

07/15/2022, 3:11 PM
That is what I'm already doing
a

Anna Geller

07/15/2022, 4:47 PM
hard to say what's wrong, could you perhaps create a minimal reproducible example repository describing your approach and the issue and share it?
7 Views