Manoj
02/12/2024, 2:26 PMJake Kaplan
02/12/2024, 4:22 PMfrom prefect import flow, task
def retry_delay_seconds_fn(num_retries: int) -> list[int]:
return [<do something based off current time> for i in range (num_retries)]
@task(retry_delay_seconds=retry_delay_seconds_fn, retries=3)
def my_task():
raise ValueError
@flow(log_prints=True)
def my_flow():
my_task()
my_flow()