diff options
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} |