From 94fba20ef625716717fb2611d7b7781cf4510ff2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Tue, 16 Apr 2024 10:53:29 +0200 Subject: [PATCH] Worker: reduce log level of some internal components Reduce the log level from 'info' to 'debug' on some internal components of Flamenco Worker. This makes the console output slightly less noisy, and it's unlikely that these particular messages are commonly needed. --- internal/worker/output_uploader.go | 4 ++-- internal/worker/upstream_buffer.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/worker/output_uploader.go b/internal/worker/output_uploader.go index d6112219..c1c4cf73 100644 --- a/internal/worker/output_uploader.go +++ b/internal/worker/output_uploader.go @@ -52,8 +52,8 @@ func (ou *OutputUploader) OutputProduced(taskID, filename string) { } func (ou *OutputUploader) Run(ctx context.Context) { - log.Info().Msg("output uploader: running") - defer log.Info().Msg("output uploader: shutting down") + log.Debug().Msg("output uploader: running") + defer log.Debug().Msg("output uploader: shutting down") wg := sync.WaitGroup{} wg.Add(1) diff --git a/internal/worker/upstream_buffer.go b/internal/worker/upstream_buffer.go index 50d7da8e..43e8d353 100644 --- a/internal/worker/upstream_buffer.go +++ b/internal/worker/upstream_buffer.go @@ -133,7 +133,7 @@ func (ub *UpstreamBufferDB) Close() error { ub.wg.Wait() // Attempt one final flush, if it's fast enough: - log.Info().Msg("upstream buffer shutting down, doing one final flush") + log.Debug().Msg("upstream buffer shutting down, doing one final flush") flushCtx, ctxCancel := context.WithTimeout(context.Background(), flushOnShutdownTimeout) defer ctxCancel() if err := ub.Flush(flushCtx); err != nil {