We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 439c308 commit 206e2e8Copy full SHA for 206e2e8
pkg/conductor/cmd/main.go
@@ -181,6 +181,15 @@ func startWorker() {
181
log.Fatal("unable to read config", err)
182
}
183
184
+ if !CLI.Debug {
185
+ encoder.SetLogger(logging.Create("encoder", logging.Prod))
186
+ manager.SetLogger(logging.Create("claim", logging.Prod))
187
+ storage.SetLogger(logging.Create("storage", logging.Prod))
188
+ ladder.SetLogger(logging.Create("ladder", logging.Prod))
189
+ mfr.SetLogger(logging.Create("mfr", logging.Prod))
190
+ dispatcher.SetLogger(logging.Create("dispatcher", logging.Prod))
191
+ }
192
+
193
s3opts := cfg.GetStringMapString("s3")
194
195
if CLI.Worker.StreamsDir != "" {
0 commit comments