Rajan Subramanian
from prefect.orion.schemas.schedules import IntervalSchedule schedule = IntervalSchedule(interval=timedelta(minutes=5)) @flow( name="redis_to_postgres_pipeline", task_runner=DaskTaskRunner(), schedule=schedule ) def run_flow(shell_task: str): cmd = build_command(shell_task) run_in_shell(command=cmd)
Kevin Kho
>>> from prefect.orion.schemas.schedules import IntervalSchedule >>> from datetime import timedelta >>> DeploymentSpec( >>> ... >>> schedule=IntervalSchedule(interval=timedelta(hours=1)) >>> )
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.