diff --git a/pipeline/05_bundle_gen/main.go b/pipeline/05_bundle_gen/main.go index 76a0397..1ce9e84 100644 --- a/pipeline/05_bundle_gen/main.go +++ b/pipeline/05_bundle_gen/main.go @@ -228,13 +228,16 @@ func main() { log.Fatalf("Failed to write bundle %d: %v", job.index, err) } + n := bundlesCreated.Add(1) + estimatedTotal := (totalHosts + cfg.EntriesPerBundle - 1) / cfg.EntriesPerBundle + if n%500 == 0 { + fmt.Printf(" %d/%d bundles\n", n, estimatedTotal) + } + logLine := fmt.Sprintf("bundle: %04d.json %dKB", job.index, len(job.data)/1024) - fmt.Println(logLine) if logWriter != nil { logWriter.Write(logLine, false) } - - bundlesCreated.Add(1) totalBytes.Add(int64(len(job.data))) } }()