hey can i enforce a complete flow retry when task fails instead of only retrying from the task that failed?
k
Kevin Kho
07/25/2021, 3:19 PM
Hey @Dotan Asselmann, ultimately you have to create a new flow run because the tasks of the current flow run have already succeeded by that point.
You can do this by using a state handler attached to the flow that kicks off a new run is the state is Failed. I think the easiest way to do this is to use the
StartFlowRun
inside the state handler and call the run method explicitly like
StartFlowRun(…).run()
.
Then you can pass the scheduled_start_time to schedule it. I don’t know if this is your intention but you might run into an infinite loop here.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.