Skip to content

Commit

Permalink
aws_opensearchserverless_lifecycle_policy: tidy
Browse files Browse the repository at this point in the history
  • Loading branch information
johnsonaj committed Nov 1, 2023
1 parent a3be0d7 commit 14c3fe9
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 10 deletions.
14 changes: 7 additions & 7 deletions internal/service/opensearchserverless/find.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/aws/aws-sdk-go-v2/service/opensearchserverless"
"github.com/aws/aws-sdk-go-v2/service/opensearchserverless/types"
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/retry"
"github.com/hashicorp/terraform-provider-aws/internal/errs"
"github.com/hashicorp/terraform-provider-aws/internal/tfresource"
)

Expand Down Expand Up @@ -176,15 +177,14 @@ func findLifecyclePolicyByNameAndType(ctx context.Context, conn *opensearchserve
}

out, err := conn.BatchGetLifecyclePolicy(ctx, in)
if err != nil {
var nfe *types.ResourceNotFoundException
if errors.As(err, &nfe) {
return nil, &retry.NotFoundError{
LastError: err,
LastRequest: in,
}
if errs.IsA[*types.ResourceNotFoundException](err) {
return nil, &retry.NotFoundError{
LastError: err,
LastRequest: in,
}
}

if err != nil {
return nil, err
}

Expand Down
1 change: 0 additions & 1 deletion internal/service/opensearchserverless/lifecycle_policy.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,6 @@ const (

type resourceLifecyclePolicy struct {
framework.ResourceWithConfigure
framework.WithTimeouts
}

func (r *resourceLifecyclePolicy) Metadata(_ context.Context, _ resource.MetadataRequest, resp *resource.MetadataResponse) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ func (d *dataSourceLifecyclePolicy) Read(ctx context.Context, req datasource.Rea
out, err := findLifecyclePolicyByNameAndType(ctx, conn, data.Name.ValueString(), data.Type.ValueString())
if err != nil {
resp.Diagnostics.AddError(
create.ProblemStandardMessage(names.OpenSearchServerless, create.ErrActionReading, DSNameLifecyclePolicy, data.Name.String(), err),
create.ProblemStandardMessage(names.OpenSearchServerless, create.ErrActionReading, DSNameLifecyclePolicy, data.Name.ValueString(), err),
err.Error(),
)
return
Expand All @@ -107,7 +107,7 @@ func (d *dataSourceLifecyclePolicy) Read(ctx context.Context, req datasource.Rea

if err != nil {
resp.Diagnostics.AddError(
create.ProblemStandardMessage(names.OpenSearchServerless, create.ErrActionReading, DSNameLifecyclePolicy, data.Name.String(), err),
create.ProblemStandardMessage(names.OpenSearchServerless, create.ErrActionReading, DSNameLifecyclePolicy, data.Name.ValueString(), err),
err.Error(),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,8 @@ func TestAccOpenSearchServerlessLifecyclePolicy_basic(t *testing.T) {
Check: resource.ComposeTestCheckFunc(
testAccCheckLifecyclePolicyExists(ctx, resourceName, &lifecyclepolicy),
resource.TestCheckResourceAttr(resourceName, "type", "retention"),
resource.TestCheckResourceAttrSet(resourceName, "policy"),
resource.TestCheckResourceAttrSet(resourceName, "policy_version"),
),
},
{
Expand Down

0 comments on commit 14c3fe9

Please sign in to comment.