diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go
index 3d96d2a..f6d9381 100644
--- a/internal/cmd/worker.go
+++ b/internal/cmd/worker.go
@@ -52,7 +52,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command {
 
 			tracer := otel.Tracer(tag)
 
-			poolSize := consumers / 16
+			poolSize := consumers / 8
 
 			db, err := cmdutil.NewDatabasePool(ctx, poolSize)
 			if err != nil {