Skip to content

Commit 33f04e5

Browse files
Merge pull request #330 from bmsiegel/request-in-progress
Retry on RequestInProgressException
2 parents 179e6a7 + d771ea3 commit 33f04e5

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/controllers/genericissuer_controller.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,10 @@ import (
2323
"os"
2424

2525
"github.com/aws/aws-sdk-go-v2/aws"
26+
"github.com/aws/aws-sdk-go-v2/aws/retry"
2627
"github.com/aws/aws-sdk-go-v2/config"
2728
"github.com/aws/aws-sdk-go-v2/credentials"
29+
acmpcaTypes "github.com/aws/aws-sdk-go-v2/service/acmpca/types"
2830
"github.com/aws/aws-sdk-go-v2/service/sts"
2931
api "github.com/cert-manager/aws-privateca-issuer/pkg/api/v1beta1"
3032
awspca "github.com/cert-manager/aws-privateca-issuer/pkg/aws"
@@ -86,6 +88,10 @@ func (r *GenericIssuerReconciler) Reconcile(ctx context.Context, req ctrl.Reques
8688
return ctrl.Result{}, cfgErr
8789
}
8890

91+
cfg.Retryer = func() aws.Retryer {
92+
return retry.AddWithErrorCodes(retry.NewStandard(), (*acmpcaTypes.RequestInProgressException)(nil).ErrorCode())
93+
}
94+
8995
if r.GetCallerIdentity {
9096
id, err := sts.NewFromConfig(cfg).GetCallerIdentity(ctx, &sts.GetCallerIdentityInput{})
9197
if err != nil {

0 commit comments

Comments
 (0)