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() ....