Robin
12/12/2023, 12:04 PMmira
12/12/2023, 1:56 PMflow.deploy(
"deployment_name",
work_pool_name=work_pool_name,
job_variables=job_variables,
image=DeploymentImage(
name=name,
tag=os.getenv("IMAGE_TAG"),
dockerfile=cfd / "Dockerfile",
),
build=True,
push=push,
triggers=[
DeploymentTrigger(
match={"prefect.resource.id": "entsoe-msg-webhook-id"},
parameters={"event_msg": "{{ event.payload.body }}"},
)
],
)