Merge pull request #364 from databacker/fix-log-levels

when creating logger from existing one WithFields, ensure applying existing log levels

pkg/core/dump.go

@@ -30,6 +30,7 @@ func (e *Executor) Dump(opts DumpOptions) (DumpResults, error) {
 	maxAllowedPacket := opts.MaxAllowedPacket
 	filenamePattern := opts.FilenamePattern
 	logger := e.Logger.WithField("run", opts.Run.String())
+	logger.Level = e.Logger.Level
 
 	now := time.Now()
 	results.Time = now

pkg/core/prune.go

@@ -15,6 +15,7 @@ var filenameRE = regexp.MustCompile(`^db_backup_(\d{4})-(\d{2})-(\d{2})T(\d{2})[
 // Prune prune older backups
 func (e *Executor) Prune(opts PruneOptions) error {
 	logger := e.Logger.WithField("run", opts.Run.String())
+	logger.Level = e.Logger.Level
 	logger.Info("beginning prune")
 	var (
 		candidates []string

pkg/core/restore.go

@@ -19,6 +19,7 @@ const (
 // Restore restore a specific backup into the database
 func (e *Executor) Restore(opts RestoreOptions) error {
 	logger := e.Logger.WithField("run", opts.Run.String())
+	logger.Level = e.Logger.Level
 
 	logger.Info("beginning restore")
 	// execute pre-restore scripts if any

pkg/log/telemetry.go

@@ -74,6 +74,7 @@ func (t *telemetry) Fire(entry *log.Entry) error {
 				defer func() { ch <- len(entries) }()
 			}
 			l := entry.Logger.WithField(sourceField, sourceTelemetry)
+			l.Level = entry.Logger.Level
 			remoteEntries := make([]LogEntry, len(entries))
 			for i, entry := range entries {
 				// send the structured data to the telemetry endpoint