diff --git a/src/internal/operations/backup.go b/src/internal/operations/backup.go index c4f547f47..e44f1ba56 100644 --- a/src/internal/operations/backup.go +++ b/src/internal/operations/backup.go @@ -596,6 +596,11 @@ func (op *BackupOperation) persistResults( opStats.writeErr) } + op.Results.BytesRead = opStats.k.TotalHashedBytes + op.Results.BytesUploaded = opStats.k.TotalUploadedBytes + op.Results.ItemsWritten = opStats.k.TotalFileCount + op.Results.ResourceOwners = opStats.resourceCount + if opStats.gc == nil { op.Status = Failed return errors.New("data population never completed") @@ -605,11 +610,7 @@ func (op *BackupOperation) persistResults( op.Status = NoData } - op.Results.BytesRead = opStats.k.TotalHashedBytes - op.Results.BytesUploaded = opStats.k.TotalUploadedBytes op.Results.ItemsRead = opStats.gc.Successful - op.Results.ItemsWritten = opStats.k.TotalFileCount - op.Results.ResourceOwners = opStats.resourceCount return nil } diff --git a/src/internal/operations/restore.go b/src/internal/operations/restore.go index c94c69a4c..aa9229336 100644 --- a/src/internal/operations/restore.go +++ b/src/internal/operations/restore.go @@ -257,6 +257,10 @@ func (op *RestoreOperation) persistResults( opStats.writeErr) } + op.Results.BytesRead = opStats.bytesRead.NumBytes + op.Results.ItemsRead = len(opStats.cs) // TODO: file count, not collection count + op.Results.ResourceOwners = opStats.resourceCount + if opStats.gc == nil { op.Status = Failed return errors.New("data restoration never completed") @@ -266,10 +270,7 @@ func (op *RestoreOperation) persistResults( op.Status = NoData } - op.Results.BytesRead = opStats.bytesRead.NumBytes - op.Results.ItemsRead = len(opStats.cs) // TODO: file count, not collection count op.Results.ItemsWritten = opStats.gc.Successful - op.Results.ResourceOwners = opStats.resourceCount dur := op.Results.CompletedAt.Sub(op.Results.StartedAt)