alex
02/17/2023, 10:37 PM@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?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.)
Marwan Sarieddine
02/17/2023, 11:22 PM