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