David Haynes
04/11/2022, 6:20 PMAnna Geller
04/11/2022, 6:23 PMprefect.engine
e.g.:
from prefect.engine.state import Failed, Retrying, ...
David Haynes
04/11/2022, 6:31 PMAnna Geller
04/11/2022, 6:33 PMDavid Haynes
04/11/2022, 6:33 PMAnna Geller
04/11/2022, 6:34 PMDavid Haynes
04/11/2022, 6:34 PMKevin Kho
04/11/2022, 6:34 PMdef state_handler(obj: Flow, old_state: State, new_state: State) -> Optional[State]:
"""
if new_state.is_finished():
if new_state.is_failed():
....
if new_state.is_successful():
....
return new_state
David Haynes
04/11/2022, 6:35 PMKevin Kho
04/11/2022, 6:36 PMprefect.engine
David Haynes
04/11/2022, 6:36 PMKevin Kho
04/11/2022, 6:36 PMAnna Geller
04/11/2022, 6:36 PMDavid Haynes
04/11/2022, 6:37 PM