Deceivious
07/12/2023, 8:52 AMGiacomo Chiarella
07/12/2023, 9:07 AMDeceivious
07/12/2023, 9:18 AMGiacomo Chiarella
07/12/2023, 9:20 AMawait client.create_work_queue(name=work_queue_name, priority=priority,
concurrency_limit=work_queue_concurrency, work_pool_name=work_pool_name)
d = Deployment.build_from_flow(flow, deployment_name, skip_upload=True)
d.work_queue_name = work_queue_name
d.apply()
d.upload_to_storage(ignore_file=None)
something like this, I do not have a working example to shareDeceivious
07/12/2023, 9:23 AMGiacomo Chiarella
07/12/2023, 9:25 AMDeceivious
07/12/2023, 9:28 AMGiacomo Chiarella
07/12/2023, 9:32 AMDeceivious
07/12/2023, 9:35 AMGiacomo Chiarella
07/12/2023, 9:42 AMDeceivious
07/12/2023, 11:46 AMasync def copy_deployment(client):
deployment = await client.read_deployment_by_name(
f"{FLOW_NAME}/{DEPLOYMENT_NAME}"
)
infra_block= None
if deployment.infrastructure_document_id:
infra_doc=await client.read_block_document(deployment.infrastructure_document_id)
infra_block = Block._from_block_document(infra_doc)
storage_block=None
if deployment.storage_document_id:
storage_doc=await client.read_block_document(deployment.infrastructure_document_id)
storage_block = Block._from_block_document(storage_doc)
deployment = Deployment(
name=f"backfill-{deployment.name}",
description=f"BACKFILL FOR {deployment.description}",
tags=["backfill", *deployment.tags],
is_schedule_active=False,
work_pool_name="default-agent-pool",
work_queue_name="manual_back_fill",
flow_name=FLOW_NAME,
parameters=deployment.parameters,
infrastructure=infra_block,
infra_overrides=deployment.infra_overrides,
storage=storage_block,
path=deployment.path,
entrypoint=deployment.entrypoint,
parameter_openapi_schema=deployment.parameter_openapi_schema,
)
await deployment.apply()
return f"{FLOW_NAME}/backfill-{deployment.name}"