Raimundo Pereira De Souza Neto
prefect=2.0a12
from prefect import flow, task @task() def s1(message): print(message) @flow() # where I put schedule params? def update_flow() -> None: s1("hello prefect")
Anna Geller
from prefect.deployments import DeploymentSpec from prefect.orion.schemas.schedules import IntervalSchedule from datetime import timedelta DeploymentSpec( flow_location="/Developer/workflows/my_flow.py", name="my-first-deployment", parameters={"nums": [1, 2, 3, 4]}, schedule=IntervalSchedule(interval=timedelta(minutes=15)), )
Zanie
CronSchedule
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.