Robin
mira
flow.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 }}"}, ) ], )
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.