Rajan Subramanian
03/02/2022, 6:23 PMfrom 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)
Getting an error, flow doesn't accept schedule as argument anymoreKevin Kho
03/02/2022, 6:25 PMRajan Subramanian
03/02/2022, 6:27 PMKevin Kho
03/02/2022, 6:32 PM>>> from prefect.orion.schemas.schedules import IntervalSchedule
>>> from datetime import timedelta
>>> DeploymentSpec(
>>> ...
>>> schedule=IntervalSchedule(interval=timedelta(hours=1))
>>> )