Alec Taggart
10/27/2023, 6:13 PMfor flow_name, params in flows.items():
base_name = flow_name.split('_flow')[0]
file_name = f"{base_name}.py"
deployment_name = f"{base_name}_deployment"
print(f"Updating {deployment_name} ...")
deployment = Deployment.build_from_flow(
flow = params.get("flow"),
name = deployment_name,
schedule = params.get("schedule"),
work_pool_name = DEFAULT_AGENT_POOL,
storage = BitBucketRepository.load("<repo-name>"),
path = REMOTE_STORAGE_PATH,
entrypoint = f"{FLOWS_PATH}{file_name}:{flow_name}",
tags=DEFAULT_TAGS
)
deployment.apply()
Alec Taggart
10/27/2023, 6:14 PM