Hi folks, I am trying to programmatically “timeout a flow run” by marking it as failed using

prefect.client.client.Client

- looking at the docs I see:

set_flow_run_state(
        self, flow_run_id: str, version: int, state: "prefect.engine.state.State"
    )

where I can pass the

flow_run_id

and

state

, but I am trying to understand the intuition behind setting

version

Would I have to find the version of the task the flow is currently on and increment it ?

Hi Marwan - that

version

is there for our “version locking” feature (which is currently only available on paid versions of Prefect Cloud), that ensures no tasks or flows are ever run twice. Basically it forces any client that ever attempts to update state to prove it is doing so with the latest state information (by providing the correct version number, otherwise an error is produced). If you aren’t on a paid Cloud plan, then you can provide any integer there with no effect.

@Chris White - gotcha, thanks for the prompt response !

👍 anytime!