When calling

Deployment.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.4

You should just be able to pass in work_pool_name='bla' - docs possibly slow to be updated

Ah...the docstring has not been updated to match the function definition.

So I changed from

Deployment.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'

not tried it myself, can you try a new deployment?

I changed the name of the flow and redeployed, then kicked off a flow-run. This time the work_queue_name shows up as

default

as expected.

with the pool?

I changed the name of the flow, then redployed as

Deployment.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.

if 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

)