diff options
Diffstat (limited to 'cmd/praefect/main.go')
| -rw-r--r-- | cmd/praefect/main.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cmd/praefect/main.go b/cmd/praefect/main.go index 2cba3aac7..555576017 100644 --- a/cmd/praefect/main.go +++ b/cmd/praefect/main.go @@ -281,6 +281,7 @@ func run(cfgs []starter.Config, conf config.Config) error { nodeManager, praefect.WithDelayMetric(delayMetric), praefect.WithLatencyMetric(latencyMetric), + praefect.WithDequeueBatchSize(1), ) srvFactory = praefect.NewServerFactory( conf, |