Alexandru Anghel
from tasks.date import get_start_date @task(name='Generate start date', retries=2, retry_delay_seconds=10)(get_start_date)
task.fn()
Ryan Peden
from prefect import flow, task from tasks.date import get_start_date get_start_date_task = task(get_start_date, name='Generate start date', retries=2, retry_delay_seconds=10) # you can now call get_start_date_task inside a flow @flow def my_flow(): start_date = get_start_date_task()
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.