From 206e2e8db1c9db2f760e6717e86be10c81026dc1 Mon Sep 17 00:00:00 2001 From: Andriy Biletsky Date: Thu, 11 Jul 2024 22:18:04 +0700 Subject: [PATCH] Fix worker log level setting --- pkg/conductor/cmd/main.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/pkg/conductor/cmd/main.go b/pkg/conductor/cmd/main.go index ac9b5e0..77706e9 100644 --- a/pkg/conductor/cmd/main.go +++ b/pkg/conductor/cmd/main.go @@ -181,6 +181,15 @@ func startWorker() { log.Fatal("unable to read config", err) } + if !CLI.Debug { + encoder.SetLogger(logging.Create("encoder", logging.Prod)) + manager.SetLogger(logging.Create("claim", logging.Prod)) + storage.SetLogger(logging.Create("storage", logging.Prod)) + ladder.SetLogger(logging.Create("ladder", logging.Prod)) + mfr.SetLogger(logging.Create("mfr", logging.Prod)) + dispatcher.SetLogger(logging.Create("dispatcher", logging.Prod)) + } + s3opts := cfg.GetStringMapString("s3") if CLI.Worker.StreamsDir != "" {