Artem Vysotsky
05/08/2022, 3:44 PMimport flow
from prefect.deployments import DeploymentSpec
from prefect.orion.schemas.schedules import CronSchedule
def create_deployment(name: str,
user_id: str,
job_id: str,
schedule: str):
d = DeploymentSpec(
flow=flow.flow,
name=name,
schedule=CronSchedule(
cron=schedule
),
parameters={
user_id: user_id,
job_id: job_id
}
)
d.create_deployment()
Kevin Kho
05/08/2022, 4:31 PMArtem Vysotsky
05/08/2022, 4:47 PM