Marwan Sarieddine06/24/2020, 4:59 PM
- looking at the docs I see:
where I can pass the
set_flow_run_state( self, flow_run_id: str, version: int, state: "prefect.engine.state.State" )
, but I am trying to understand the intuition behind setting
Would I have to find the version of the task the flow is currently on and increment it ?
referencing the task version or the flow version ? [if it is the flow version, why is that needed given I am passing the
) if it is the task version - why do I have to manually set it instead of prefect incrementing it for me ?
Chris White06/24/2020, 5:05 PM
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.
Marwan Sarieddine06/24/2020, 5:08 PM
Chris White06/24/2020, 5:08 PM