Stephanie Vandenberg
prefect.context.get_run_context()
deployment_id = None
for config in flows_config: deployment = Deployment.build_from_flow( flow=config['flow'], name=config['name'], work_queue_name=work_queue_name, storage=storage, infrastructure=config['infrastructure'], tags=config['tags'], path="", schedule=config.get('schedule'), is_schedule_active=config['is_schedule_active'] ) deployments.append(deployment) for deployment in deployments: deployment.apply()
Uriel Mandujano
get_run_context
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.