From 5c12f6ade6ebd444f05175a658e6b70bdde5046f Mon Sep 17 00:00:00 2001
From: Rasmus Dahlberg <rasmus@rgdd.se>
Date: Sat, 18 Mar 2023 16:55:50 +0000
Subject: Tune number of workers

---
 cmd_collect.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'cmd_collect.go')

diff --git a/cmd_collect.go b/cmd_collect.go
index 2444d95..4402905 100644
--- a/cmd_collect.go
+++ b/cmd_collect.go
@@ -95,7 +95,7 @@ func collect(opts options) error {
 				BatchSize:     int(opts.BatchSize),
 				StartIndex:    th.TreeSize,
 				EndIndex:      int64(sth.TreeSize),
-				ParallelFetch: int(opts.WorkersPerLog),
+				ParallelFetch: maxWorkers(log, opts.WorkersPerLog),
 			})
 			if uint64(th.TreeSize) == sth.TreeSize {
 				metricsCh <- metrics{Description: *log.Description, End: th.TreeSize, Done: true}
-- 
cgit v1.2.3