Skip to content

Commit 7a65341

Browse files
committed
sdkDelete does not delete replicas
1 parent 11a5690 commit 7a65341

File tree

5 files changed

+4
-36
lines changed

5 files changed

+4
-36
lines changed

Diff for: apis/v1alpha1/ack-generate-metadata.yaml

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
ack_generate_info:
2-
build_date: "2025-03-24T15:20:40Z"
2+
build_date: "2025-03-27T17:32:01Z"
33
build_hash: 3722729cebe6d3c03c7e442655ef0846f91566a2
4-
go_version: go1.24.0
4+
go_version: go1.24.1
55
version: v0.43.2-7-g3722729
66
api_directory_checksum: cb49386ebd7bb50e2521072a76262c72b9dbd285
77
api_version: v1alpha1

Diff for: pkg/resource/table/hooks.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ func (rm *resourceManager) customUpdateTable(
236236
case delta.DifferentAt("Spec.TableReplicas"):
237237
// Enabling replicas required streams enabled and StreamViewType to be NEW_AND_OLD_IMAGES
238238
// Version 2019.11.21 TableUpdate API requirement
239-
if !hasStreamSpecificationWithNewAndOldImages(desired) {
239+
if !hasStreamSpecificationWithNewAndOldImages(desired) {
240240
msg := "table must have DynamoDB Streams enabled with StreamViewType set to NEW_AND_OLD_IMAGES for replica updates"
241241
rlog.Debug(msg)
242242
return nil, ackerr.NewTerminalError(errors.New(msg))

Diff for: pkg/resource/table/sdk.go

-16
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Diff for: templates/hooks/table/sdk_delete_pre_build_request.go.tpl

-16
Original file line numberDiff line numberDiff line change
@@ -4,19 +4,3 @@
44
if isTableUpdating(r) {
55
return nil, requeueWaitWhileUpdating
66
}
7-
8-
// If there are replicas, we need to remove them before deleting the table
9-
if len(r.ko.Spec.TableReplicas) > 0 {
10-
desired := &resource{
11-
ko: r.ko.DeepCopy(),
12-
}
13-
desired.ko.Spec.TableReplicas = nil
14-
15-
err := rm.syncReplicas(ctx, r, desired)
16-
if err != nil {
17-
return nil, err
18-
}
19-
// Requeue to wait for replica removal to complete before attempting table deletion
20-
// When syncReplicas returns an error other than requeue
21-
return r, requeueWaitWhileDeleting
22-
}

Diff for: templates/hooks/table/sdk_read_one_post_set_output.go.tpl

+1-1
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
} else {
5454
ko.Spec.BillingMode = aws.String("PROVISIONED")
5555
}
56-
setTableReplicas(r, resp.Table.Replicas)
56+
setTableReplicas(ko, resp.Table.Replicas)
5757
if isTableCreating(&resource{ko}) {
5858
return &resource{ko}, requeueWaitWhileCreating
5959
}

0 commit comments

Comments
 (0)