Question regarding result persistence and restarting failed flows:
I have a flow that resembles this that I am running locally and on kubernetes
Copy code
@flow
def demo_flow(x=1):
val = task_1(x)
val = task_2(val)
val = task_3(val)
val = task_4(val)
val = prone_to_fail_task(val)
return val
If expensive_prone_to_fail_task fails, I want to be able to restart my flow and have it retry just
prone_to_fail_task
again. What do I need to achieve that? Will adding
cache_key_fn=task_input_hash,
to just
task_4
be sufficient?
alex
02/17/2023, 10:40 PM
I'm getting this error currently when trying to restart from the UI
Copy code
raise MissingResult(
prefect.exceptions.MissingResult: State data is missing. Typically, this occurs when result persistence is disabled and the state has been retrieved from the API.)
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.