From bcf20fb800fe854d7b91b94e9102ef094d2a4834 Mon Sep 17 00:00:00 2001 From: Marvin Preuss Date: Thu, 13 Jan 2022 13:02:18 +0100 Subject: [PATCH] fix: removes own logger with caller --- workgroups.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/workgroups.go b/workgroups.go index 6720a09..135a109 100644 --- a/workgroups.go +++ b/workgroups.go @@ -70,8 +70,8 @@ func NewDispatcher(ctx context.Context, numWorkers, workLength int) (*Dispatcher // Start starts the configured number of workers and waits for jobs. func (d *Dispatcher) Start() { for i := 0; i < d.numWorkers; i++ { - logger := log.With().Caller().Int("worker", i).Logger() - logger.Info().Msg("starting worker") + logger := log.With().Int("worker", i).Logger() + logger.Debug().Msg("starting worker") d.eg.Go(func() error { for j := range d.queue { @@ -91,7 +91,7 @@ func (d *Dispatcher) Start() { } } - logger.Info().Msg("no work. returning...") + logger.Debug().Msg("no work. returning...") return nil })