jack
03/07/2023, 9:15 PMDeployment.build_from_flow()
how do we specify a work pool? The docstring for Deployment
shows a work_queue
keyword argument but not one for work_pool
.
The docs for work queues say that work queues are an advanced topic. Are we to used work queues or work pools to get certain deployments to be run by certain agents?
Using prefect 2.8.4redsquare
03/07/2023, 9:26 PMjack
03/07/2023, 9:28 PMjack
03/07/2023, 9:34 PMDeployment.build_from_flow(work_queue_name='some-queue')
to
Deployment.build_from_flow(work_pool_name='some-queue')
and redeployed to a new version number and kicked off a flow-run, but in the UI it still shows work_queue_name='some-queue'
redsquare
03/07/2023, 9:35 PMjack
03/07/2023, 9:38 PMdefault
as expected.redsquare
03/07/2023, 9:41 PMjack
03/07/2023, 9:43 PMDeployment.build_from_flow(work_pool_name='some-queue')
In the UI it now shows default
for work_queue_name, as expected. Unfortunately, the UI does not show the work_pool_name
at all.redsquare
03/07/2023, 9:45 PMif self.work_queue_name and work_queue_concurrency is not None:
try:
res = await client.create_work_queue(
name=self.work_queue_name, work_pool_name=self.work_pool_name
)
except ObjectAlreadyExists:
res = await client.read_work_queue_by_name(
name=self.work_queue_name, work_pool_name=self.work_pool_name
)
await client.update_work_queue(
res.id, concurrency_limit=work_queue_concurrency
)