diff options
| author | Rasmus Dahlberg <rasmus@rgdd.se> | 2023-03-18 16:55:50 +0000 |
|---|---|---|
| committer | Rasmus Dahlberg <rasmus@rgdd.se> | 2023-03-18 17:58:25 +0100 |
| commit | 5c12f6ade6ebd444f05175a658e6b70bdde5046f (patch) | |
| tree | 5cb859351bca1ac2fe1b41896334c79fea045494 /cmd_collect.go | |
| parent | 4233dde13c61f492023166c6bafda85ba7bb08b3 (diff) | |
Tune number of workers
Diffstat (limited to 'cmd_collect.go')
| -rw-r--r-- | cmd_collect.go | 2 |
1 files changed, 1 insertions, 1 deletions
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} |