diff --git a/pkg/util/backoff/general.go b/pkg/util/backoff/general.go index e91da06b3..19ae49ace 100644 --- a/pkg/util/backoff/general.go +++ b/pkg/util/backoff/general.go @@ -2,6 +2,7 @@ package backoff import ( "context" + "time" "github.com/cenkalti/backoff/v4" ) @@ -9,7 +10,10 @@ import ( var MaxRetries uint64 = 101 // RetryGeneral retries operation with max retry times 101 and with the exponential backoff -func RetryGeneral(ctx context.Context, op backoff.Operation) (err error) { +func RetryGeneral(parent context.Context, op backoff.Operation) (err error) { + ctx, cancel := context.WithTimeout(parent, 15*time.Minute) + defer cancel() + err = backoff.Retry(op, backoff.WithContext( backoff.WithMaxRetries( backoff.NewExponentialBackOff(),