Sanz Al
08/22/2023, 2:40 PMJeff Hale
08/23/2023, 11:51 AMfrom prefect import task, flow
@task()
def task1():
print("trying task 1")
@task()
def task2():
print("trying task 2")
raise ValueError("fail")
@flow(retries=2, log_prints=True)
def run_tasks():
task1()
task2()
if __name__ == "__main__":
run_tasks()
Sanz Al
08/24/2023, 7:03 AM