max
09/21/2022, 6:58 AMStéphan Taljaard
09/21/2022, 9:33 AMmax
09/21/2022, 10:49 AMmy_flow_deployment = Deployment(
flow=my_flow,
flow_runner=SubprocessFlowRunner(),
schedule=IntervalSchedule(
interval=datetime.timedelta(hours=3),
anchor_date=datetime.datetime.utcnow().replace(tzinfo=utc)
),
)
and deploying like this:
deployment_id = await my_flow_deployment.create(client=prefect_client)
await prefect_client.create_flow_run_from_deployment(deployment_id=deployment_id)
ps. if I remove running flow after the deployment, prefect server will run my flow only at the next date, but I wanted to run it just when deployed.