larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix cherry pick conflicts

Browse Source
This commit is contained in:
ryanfkeepers 2023-03-22 15:18:49 -06:00
parent 77c6495bda
commit 8299bb30c4
1 changed files with 3 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/internal/operations/backup.go
View File

@ -664,10 +664,6 @@ func (op *BackupOperation) createBackupModels(
deets *details.Details,
) error {
ctx = clues.Add(ctx, "snapshot_id", snapID, "backup_id", backupID)
// generate a new fault bus so that we can maintain clean
// separation between the errors we serialize and those that
// are generated during the serialization process.
errs := fault.New(true)
if deets == nil {
return clues.New("no backup details to record").WithClues(ctx)
@ -675,22 +671,12 @@ func (op *BackupOperation) createBackupModels(
ctx = clues.Add(ctx, "details_entry_count", len(deets.Entries))
err := sscw.Collect(ctx, streamstore.DetailsCollector(deets))
detailsID, err := detailsStore.Write(ctx, deets, op.Errors)
if err != nil {
return clues.Wrap(err, "collecting details for persistence").WithClues(ctx)
return clues.Wrap(err, "creating backupDetails model").WithClues(ctx)
}
err = sscw.Collect(ctx, streamstore.FaultErrorsCollector(op.Errors.Errors()))
if err != nil {
return clues.Wrap(err, "collecting errors for persistence").WithClues(ctx)
}
ssid, err := sscw.Write(ctx, errs)
if err != nil {
return clues.Wrap(err, "persisting details and errors").WithClues(ctx)
}
ctx = clues.Add(ctx, "streamstore_snapshot_id", ssid)
ctx = clues.Add(ctx, "details_snapshot_id", detailsID)
b := backup.New(
snapID, detailsID, op.Status.String(),