Dominik Wagner
07/26/2022, 1:28 PM@flow
def my_flow():
if <somehow_get_state_of_this_flow?> == "Retrying":
do_something()
Anna Geller
07/26/2022, 1:32 PMif task.get_state().is_failed():
if task.get_state().is_retrying():
@task
def do_sth():
...
@flow
def my_flow():
if do_sth.submit().get_state().is_retrying():
do_something()
Dominik Wagner
07/26/2022, 1:37 PMshell_run_command()
from prefect_shell
, and I don’t think I can add retries there?Anna Geller
07/26/2022, 1:38 PMDominik Wagner
07/26/2022, 1:41 PM