Sophia Ponte
12/15/2023, 5:29 PMmain_flow
which calls a subflow
which calls 2 sequential tasks. I cause the second task to fail. When I retry the main flow from the UI, it spawns a new subflow
run instead of retrying the existing subflow
. This causes task1
in the subflow
to re-execute, despite it's already succeeded state in the initial flow run.
@flow
def main_flow():
subflow.with_options(persist_result=True, result_storage=FLOW_STORAGE)()
@flow
def subflow():
task1.with_options(persist_result=True, result_storage=FLOW_STORAGE)()
task2.with_options(persist_result=True, result_storage=FLOW_STORAGE)()
@task
def task1():
print("running task 1")
@task
def task2():
print("running task 2")
raise RuntimeError
# deploy main_flow() ....