> ## Documentation Index
> Fetch the complete documentation index at: /docs/llms.txt
> Use this file to discover all available pages before exploring further.

# work_queue

# `prefect.cli.work_queue`

Work queue command — native cyclopts implementation.

Manage work queues.

## Functions

### `create` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L68](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L68)</sup>

```python theme={null}
create(name: Annotated[str, cyclopts.Parameter(help='The unique name to assign this work queue')])
```

Create a work queue.

### `set_concurrency_limit` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L137](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L137)</sup>

```python theme={null}
set_concurrency_limit(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue')], limit: Annotated[int, cyclopts.Parameter(help='The concurrency limit to set on the queue.')])
```

Set a concurrency limit on a work queue.

### `clear_concurrency_limit` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L188](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L188)</sup>

```python theme={null}
clear_concurrency_limit(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to clear')])
```

Clear any concurrency limits from a work queue.

### `pause` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L234](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L234)</sup>

```python theme={null}
pause(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to pause')])
```

Pause a work queue.

### `resume` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L292](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L292)</sup>

```python theme={null}
resume(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to resume')])
```

Resume a paused work queue.

### `inspect` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L337](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L337)</sup>

```python theme={null}
inspect(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to inspect')])
```

Inspect a work queue by ID.

### `slots` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L410](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L410)</sup>

```python theme={null}
slots(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue.')])
```

Show concurrency slot utilization for a work queue.

### `ls` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L504](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L504)</sup>

```python theme={null}
ls()
```

View all work queues.

### `preview` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L645](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L645)</sup>

```python theme={null}
preview(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to preview')])
```

Preview a work queue.

### `delete` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L763](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L763)</sup>

```python theme={null}
delete(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to delete')])
```

Delete a work queue by ID.

### `read_wq_runs` <sup>[https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work\_queue.py#L812](https://github.com/PrefectHQ/prefect/blob/main/src/prefect/cli/work_queue.py#L812)</sup>

```python theme={null}
read_wq_runs(name: Annotated[str, cyclopts.Parameter(help='The name or ID of the work queue to poll')])
```

Get runs in a work queue.

Note that this will trigger an artificial poll of the work queue.
