diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go index e86fa01..a3da327 100644 --- a/internal/cmd/worker.go +++ b/internal/cmd/worker.go @@ -46,7 +46,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command { defer statsd.Close() consumers := runtime.NumCPU() * multiplier - poolSize := multiplier + poolSize := multiplier / 8 db, err := cmdutil.NewDatabasePool(ctx, poolSize) if err != nil {