Raimundo Pereira De Souza Neto
02/21/2022, 7:58 PMprefect=2.0a12
, and I would like to schedule my flow like a cronJob. It's possible with decorator?
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
type https://orion-docs.prefect.io/api-ref/orion/schemas/schedules/#prefect.orion.schemas.schedules.CronSchedule