diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go index 6fd3182..c2e0580 100644 --- a/internal/cmd/worker.go +++ b/internal/cmd/worker.go @@ -58,7 +58,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command { } defer db.Close() - redis, err := cmdutil.NewRedisLocksClient(ctx, consumers/8) + redis, err := cmdutil.NewRedisLocksClient(ctx, consumers/4) if err != nil { return err }