Skip to content

Commit

Permalink
more detailed log for cleanBackupObjectDisks
Browse files Browse the repository at this point in the history
Slach committed Jun 11, 2024
1 parent bc7b9cb commit 3b3c805
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/backup/delete.go
Original file line number Diff line number Diff line change
@@ -184,7 +184,7 @@ func (b *Backuper) cleanEmbeddedAndObjectDiskLocalIfSameRemoteNotPresent(ctx con
log.Warnf("b.cleanBackupObjectDisks return error: %v", deleteErr)
return err
} else {
log.WithField("duration", utils.HumanizeDuration(time.Since(startTime))).Infof("cleanBackupObjectDisks deleted %d keys", deletedKeys)
log.WithField("backup", backupName).WithField("duration", utils.HumanizeDuration(time.Since(startTime))).Infof("cleanBackupObjectDisks deleted %d keys", deletedKeys)
}
}
if !skip && (b.isEmbedded && b.cfg.ClickHouse.EmbeddedBackupDisk != "") {
@@ -342,7 +342,7 @@ func (b *Backuper) cleanEmbeddedAndObjectDiskRemoteIfSameLocalNotPresent(ctx con
if deletedKeys, deleteErr := b.cleanBackupObjectDisks(ctx, backup.BackupName); deleteErr != nil {
log.Warnf("b.cleanBackupObjectDisks return error: %v", deleteErr)
} else {
log.WithField("duration", utils.HumanizeDuration(time.Since(startTime))).Infof("cleanBackupObjectDisks deleted %d keys", deletedKeys)
log.WithField("backup", backup.BackupName).WithField("duration", utils.HumanizeDuration(time.Since(startTime))).Infof("cleanBackupObjectDisks deleted %d keys", deletedKeys)
}
return nil
}

0 comments on commit 3b3c805

Please sign in to comment.