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

put back dq

Browse Source
This commit is contained in:
Abhishek Pandey 2023-08-16 17:25:35 +05:30
parent b483703b47
commit 3ebb2c1c04
1 changed files with 30 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -370,15 +370,15 @@ func (op *BackupOperation) do(
} }
// Run 3 times and exit // Run 3 times and exit
//cs := []data.BackupCollection{} cs := []data.BackupCollection{}
//canUsePreviousBackup := false canUsePreviousBackup := false
//var maxCount int = 2 var maxCount int = 2
//for i := 0; i < maxCount; i++ { for i := 0; i < maxCount; i++ {
//logger.Ctx(ctx).Info("delta query iteration") logger.Ctx(ctx).Info("delta query iteration")
cs, ssmb, canUsePreviousBackup, err := produceBackupDataCollections( cs, _, canUsePreviousBackup, err := produceBackupDataCollections(
ctx, ctx,
op.bp, op.bp,
op.ResourceOwner, op.ResourceOwner,
@ -399,10 +399,10 @@ func (op *BackupOperation) do(
// sleep for 5 mins // sleep for 5 mins
//time.Sleep(5 * time.Minute) //time.Sleep(5 * time.Minute)
// if i == maxCount-1 { if i == maxCount-1 {
// return nil, clues.New("unable to produce backup collections").WithClues(ctx) return nil, clues.New("unable to produce backup collections").WithClues(ctx)
// } }
//} }
writeStats, deets, toMerge, err := consumeBackupCollections( writeStats, deets, toMerge, err := consumeBackupCollections(
ctx, ctx,
@ -411,7 +411,7 @@ func (op *BackupOperation) do(
reasons, reasons,
mans, mans,
cs, cs,
ssmb, nil,
backupID, backupID,
op.incremental && canUseMetadata && canUsePreviousBackup, op.incremental && canUseMetadata && canUsePreviousBackup,
op.Errors) op.Errors)