From bc70536a252413ad30c667fbf8a393e8f6cc6199 Mon Sep 17 00:00:00 2001 From: John Pruitt Date: Fri, 21 Oct 2022 08:22:51 -0500 Subject: [PATCH] Change log level in vacuum engine The vacuum engine was emitting too verbose logs. --- CHANGELOG.md | 8 ++++++++ pkg/vacuum/vacuum.go | 4 ++-- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index a2f992cdea..6f090e6caf 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -15,6 +15,14 @@ We use the following categories for changes: ## Unreleased +### Added + +### Changed +- Reduced the verbosity of the logs emitted by the vacuum engine [#1715] + +### Fixed + + ## [0.16.0] - 2022-10-20 ### Added diff --git a/pkg/vacuum/vacuum.go b/pkg/vacuum/vacuum.go index 9270c0de41..fb74533bab 100644 --- a/pkg/vacuum/vacuum.go +++ b/pkg/vacuum/vacuum.go @@ -135,7 +135,7 @@ func (e *Engine) Run(ctx context.Context) { return } if !acquired { - log.Info("msg", "vacuum engine did not acquire advisory lock") + log.Debug("msg", "vacuum engine did not acquire advisory lock") return } // release the advisory lock when we're done @@ -213,7 +213,7 @@ func runWorkers(ctx context.Context, parallelism int, chunks []string, worker fu // worker pulls chunks from a channel and vacuums them func (e *Engine) worker(ctx context.Context, id int, todo <-chan string) { for chunk := range todo { - log.Info("msg", "vacuuming a chunk", "worker", id, "chunk", chunk) + log.Debug("msg", "vacuuming a chunk", "worker", id, "chunk", chunk) sql := fmt.Sprintf(sqlVacuumFmt, chunk) _, err := e.pool.Exec(ctx, sql) if err != nil {