Skip to content

Commit

Permalink
changes
Browse files Browse the repository at this point in the history
  • Loading branch information
mayankagg9722 committed Apr 2, 2024
1 parent f17e699 commit 6481af2
Showing 1 changed file with 3 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ var nonRetryableStates = set.Make(
)

const (
BackupInstancePollerResumeTokenAnnotation = "dataprotection.azure.com/backupinstance/poller-resume-token"
BackupInstancePollerResumeTokenAnnotation = "serviceoperator.azure.com/bi-poller-resume-token"
)

func GetPollerResumeToken(obj genruntime.MetaObject, log logr.Logger) (string, bool) {
Expand Down Expand Up @@ -136,15 +136,13 @@ func (extension *BackupVaultsBackupInstanceExtension) PostReconcileCheck(
if err != nil {
return extensions.PostReconcileCheckResultFailure("couldn't create PUT resume token for resource"), err
} else {
log.V(Debug).Info(fmt.Sprintf("########################## Setting ResumeToken: %q ##########################", resumeToken))
SetPollerResumeToken(obj, resumeToken, log)
GetPollerResumeToken(obj, log)
}
if poller.Done() {
log.V(Debug).Info("########################## Polling is completed ##########################")
ClearPollerResumeToken(obj, log)
} else {
return next(ctx, obj, owner, resolver, armClient, log)
}
log.V(Debug).Info("########################## Polling is in-progress ##########################")
}
}
}
Expand Down

0 comments on commit 6481af2

Please sign in to comment.