diff --git a/src/internal/kopia/upload.go b/src/internal/kopia/upload.go index cca7c691f..bdd3f2444 100644 --- a/src/internal/kopia/upload.go +++ b/src/internal/kopia/upload.go @@ -877,8 +877,8 @@ func traverseBaseDir( stats *count.Bus, ) error { ctx = clues.Add(ctx, - "old_dir_path", oldDirPath, - "expected_dir_path", expectedDirPath) + "old_parent_dir_path", oldDirPath, + "expected_parent_dir_path", expectedDirPath) if depth >= maxInflateTraversalDepth { return clues.New("base snapshot tree too tall").WithClues(ctx) diff --git a/src/internal/operations/backup.go b/src/internal/operations/backup.go index 9215bc0d5..049686bcf 100644 --- a/src/internal/operations/backup.go +++ b/src/internal/operations/backup.go @@ -492,7 +492,10 @@ func consumeBackupCollections( isIncremental bool, errs *fault.Bus, ) (*kopia.BackupStats, *details.Builder, kopia.DetailsMergeInfoer, error) { - ctx = clues.Add(ctx, "collection_source", "operations") + ctx = clues.Add( + ctx, + "collection_source", "operations", + "snapshot_type", "item data") progressBar := observe.MessageWithCompletion(ctx, "Backing up data") defer close(progressBar) diff --git a/src/internal/streamstore/streamstore.go b/src/internal/streamstore/streamstore.go index 58f98f2a8..35a3b9706 100644 --- a/src/internal/streamstore/streamstore.go +++ b/src/internal/streamstore/streamstore.go @@ -61,6 +61,8 @@ func (ss *storeStreamer) Collect(ctx context.Context, col Collectable) error { // Write persists the collected objects in the stream store func (ss *storeStreamer) Write(ctx context.Context, errs *fault.Bus) (string, error) { + ctx = clues.Add(ctx, "snapshot_type", "stream store") + id, err := write(ctx, ss.kw, ss.dbcs, errs) if err != nil { return "", clues.Wrap(err, "writing to stream store")