# assert_throughput

Emits a warning if the pipeline does not have the expected throughput

```tql
assert_throughput min_events:int, within=duration, [retries=int]
```

## Description

The `assert_throughput` operator checks a pipeline’s throughput, emitting a warning if the minimum specified throughput is unmet, and optionally an error if the number of retries is exceeded.

## Examples

### Require 1,000 events per second, failing if the issue persists for 30s

```tql
accept_udp "0.0.0.0:514"
this = data.parse_syslog()
assert_throughput 1k, within=1s, retries=30
```

## See Also

* [`accept_udp`](https://preview.docs.tenzir.com/375/375/reference/operators/accept_udp.md)
* [`assert`](https://preview.docs.tenzir.com/375/375/reference/operators/assert.md)
* [`throttle`](https://preview.docs.tenzir.com/375/375/reference/operators/throttle.md)