Skip to content

Commit 3d2852a

Browse files
joaquinservettojoaquinservetto
authored
Fix DBCluster enableCloudwatchLogsExports updates (#161)
[Issue#1845](aws-controllers-k8s/community#1845) Fixes a bug where updating `enableCloudWatchLogExports` didn't work as expected. By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
1 parent fe6ee68 commit 3d2852a

File tree

5 files changed

+211
-57
lines changed

5 files changed

+211
-57
lines changed

‎pkg/resource/db_cluster/custom_update.go

Lines changed: 85 additions & 54 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ package db_cluster
1515

1616
import (
1717
"context"
18+
"slices"
1819

1920
ackv1alpha1 "github.com/aws-controllers-k8s/runtime/apis/core/v1alpha1"
2021
ackcompare "github.com/aws-controllers-k8s/runtime/pkg/compare"
@@ -63,7 +64,7 @@ func (rm *resourceManager) customUpdate(
6364
ackcondition.SetSynced(desired, corev1.ConditionTrue, nil, nil)
6465
return desired, nil
6566
}
66-
input, err := rm.newCustomUpdateRequestPayload(ctx, desired, delta)
67+
input, err := rm.newCustomUpdateRequestPayload(ctx, desired, latest, delta)
6768
if err != nil {
6869
return nil, err
6970
}
@@ -516,112 +517,142 @@ func (rm *resourceManager) customUpdate(
516517
// https://github.com/aws-controllers-k8s/community/issues/917
517518
func (rm *resourceManager) newCustomUpdateRequestPayload(
518519
ctx context.Context,
519-
r *resource,
520+
desired *resource,
521+
latest *resource,
520522
delta *ackcompare.Delta,
521523
) (*svcsdk.ModifyDBClusterInput, error) {
522524
res := &svcsdk.ModifyDBClusterInput{}
523525

524526
res.SetApplyImmediately(true)
525527
res.SetAllowMajorVersionUpgrade(true)
526-
if r.ko.Spec.BacktrackWindow != nil && delta.DifferentAt("Spec.BacktrackWindow") {
527-
res.SetBacktrackWindow(*r.ko.Spec.BacktrackWindow)
528+
if desired.ko.Spec.BacktrackWindow != nil && delta.DifferentAt("Spec.BacktrackWindow") {
529+
res.SetBacktrackWindow(*desired.ko.Spec.BacktrackWindow)
528530
}
529-
if r.ko.Spec.BackupRetentionPeriod != nil && delta.DifferentAt("Spec.BackupRetentionPeriod") {
530-
res.SetBackupRetentionPeriod(*r.ko.Spec.BackupRetentionPeriod)
531+
if desired.ko.Spec.BackupRetentionPeriod != nil && delta.DifferentAt("Spec.BackupRetentionPeriod") {
532+
res.SetBackupRetentionPeriod(*desired.ko.Spec.BackupRetentionPeriod)
531533
}
532-
if r.ko.Spec.CopyTagsToSnapshot != nil && delta.DifferentAt("Spec.CopyTagsToSnapshot") {
533-
res.SetCopyTagsToSnapshot(*r.ko.Spec.CopyTagsToSnapshot)
534+
if desired.ko.Spec.CopyTagsToSnapshot != nil && delta.DifferentAt("Spec.CopyTagsToSnapshot") {
535+
res.SetCopyTagsToSnapshot(*desired.ko.Spec.CopyTagsToSnapshot)
534536
}
535537
// NOTE(jaypipes): This is a required field in the input shape. If not set,
536538
// we get back a cryptic error message "1 Validation error(s) found."
537-
if r.ko.Spec.DBClusterIdentifier != nil {
538-
res.SetDBClusterIdentifier(*r.ko.Spec.DBClusterIdentifier)
539+
if desired.ko.Spec.DBClusterIdentifier != nil {
540+
res.SetDBClusterIdentifier(*desired.ko.Spec.DBClusterIdentifier)
539541
}
540-
if r.ko.Spec.DBClusterParameterGroupName != nil && delta.DifferentAt("Spec.DBClusterParameterGroupName") {
541-
res.SetDBClusterParameterGroupName(*r.ko.Spec.DBClusterParameterGroupName)
542+
if desired.ko.Spec.DBClusterParameterGroupName != nil && delta.DifferentAt("Spec.DBClusterParameterGroupName") {
543+
res.SetDBClusterParameterGroupName(*desired.ko.Spec.DBClusterParameterGroupName)
542544
}
543-
if r.ko.Spec.DeletionProtection != nil && delta.DifferentAt("Spec.DeletionProtection") {
544-
res.SetDeletionProtection(*r.ko.Spec.DeletionProtection)
545+
if desired.ko.Spec.DeletionProtection != nil && delta.DifferentAt("Spec.DeletionProtection") {
546+
res.SetDeletionProtection(*desired.ko.Spec.DeletionProtection)
545547
}
546-
if r.ko.Spec.Domain != nil && delta.DifferentAt("Spec.Domain") {
547-
res.SetDomain(*r.ko.Spec.Domain)
548+
if desired.ko.Spec.Domain != nil && delta.DifferentAt("Spec.Domain") {
549+
res.SetDomain(*desired.ko.Spec.Domain)
548550
}
549-
if r.ko.Spec.DomainIAMRoleName != nil && delta.DifferentAt("Spec.DomainIAMRoleName") {
550-
res.SetDomainIAMRoleName(*r.ko.Spec.DomainIAMRoleName)
551+
if desired.ko.Spec.DomainIAMRoleName != nil && delta.DifferentAt("Spec.DomainIAMRoleName") {
552+
res.SetDomainIAMRoleName(*desired.ko.Spec.DomainIAMRoleName)
551553
}
552-
if r.ko.Spec.EnableGlobalWriteForwarding != nil && delta.DifferentAt("Spec.EnableGlobalWriteForwarding") {
553-
res.SetEnableGlobalWriteForwarding(*r.ko.Spec.EnableGlobalWriteForwarding)
554+
if desired.ko.Spec.EnableGlobalWriteForwarding != nil && delta.DifferentAt("Spec.EnableGlobalWriteForwarding") {
555+
res.SetEnableGlobalWriteForwarding(*desired.ko.Spec.EnableGlobalWriteForwarding)
554556
}
555-
if r.ko.Spec.EnableHTTPEndpoint != nil && delta.DifferentAt("Spec.EnableHTTPEndpoint") {
556-
res.SetEnableHttpEndpoint(*r.ko.Spec.EnableHTTPEndpoint)
557+
if desired.ko.Spec.EnableHTTPEndpoint != nil && delta.DifferentAt("Spec.EnableHTTPEndpoint") {
558+
res.SetEnableHttpEndpoint(*desired.ko.Spec.EnableHTTPEndpoint)
557559
}
558-
if r.ko.Spec.EnableIAMDatabaseAuthentication != nil && delta.DifferentAt("Spec.EnableIAMDatabaseAuthentication") {
559-
res.SetEnableIAMDatabaseAuthentication(*r.ko.Spec.EnableIAMDatabaseAuthentication)
560+
if desired.ko.Spec.EnableIAMDatabaseAuthentication != nil && delta.DifferentAt("Spec.EnableIAMDatabaseAuthentication") {
561+
res.SetEnableIAMDatabaseAuthentication(*desired.ko.Spec.EnableIAMDatabaseAuthentication)
560562
}
561-
if r.ko.Spec.EngineVersion != nil && delta.DifferentAt("Spec.EngineVersion") {
562-
res.SetEngineVersion(*r.ko.Spec.EngineVersion)
563+
if desired.ko.Spec.EngineVersion != nil && delta.DifferentAt("Spec.EngineVersion") {
564+
res.SetEngineVersion(*desired.ko.Spec.EngineVersion)
563565
}
564-
if r.ko.Spec.MasterUserPassword != nil && delta.DifferentAt("Spec.MasterUserPassword") {
565-
tmpSecret, err := rm.rr.SecretValueFromReference(ctx, r.ko.Spec.MasterUserPassword)
566+
if desired.ko.Spec.MasterUserPassword != nil && delta.DifferentAt("Spec.MasterUserPassword") {
567+
tmpSecret, err := rm.rr.SecretValueFromReference(ctx, desired.ko.Spec.MasterUserPassword)
566568
if err != nil {
567569
return nil, err
568570
}
569571
if tmpSecret != "" {
570572
res.SetMasterUserPassword(tmpSecret)
571573
}
572574
}
573-
if r.ko.Spec.OptionGroupName != nil && delta.DifferentAt("Spec.OptionGroupName") {
574-
res.SetOptionGroupName(*r.ko.Spec.OptionGroupName)
575+
if desired.ko.Spec.OptionGroupName != nil && delta.DifferentAt("Spec.OptionGroupName") {
576+
res.SetOptionGroupName(*desired.ko.Spec.OptionGroupName)
575577
}
576-
if r.ko.Spec.Port != nil && delta.DifferentAt("Spec.Port") {
577-
res.SetPort(*r.ko.Spec.Port)
578+
if desired.ko.Spec.Port != nil && delta.DifferentAt("Spec.Port") {
579+
res.SetPort(*desired.ko.Spec.Port)
578580
}
579-
if r.ko.Spec.PreferredBackupWindow != nil && delta.DifferentAt("Spec.PreferredBackupkWindow") {
580-
res.SetPreferredBackupWindow(*r.ko.Spec.PreferredBackupWindow)
581+
if desired.ko.Spec.PreferredBackupWindow != nil && delta.DifferentAt("Spec.PreferredBackupkWindow") {
582+
res.SetPreferredBackupWindow(*desired.ko.Spec.PreferredBackupWindow)
581583
}
582-
if r.ko.Spec.PreferredMaintenanceWindow != nil && delta.DifferentAt("Spec.PreferredMaintenanceWindow") {
583-
res.SetPreferredMaintenanceWindow(*r.ko.Spec.PreferredMaintenanceWindow)
584+
if desired.ko.Spec.PreferredMaintenanceWindow != nil && delta.DifferentAt("Spec.PreferredMaintenanceWindow") {
585+
res.SetPreferredMaintenanceWindow(*desired.ko.Spec.PreferredMaintenanceWindow)
584586
}
585-
if r.ko.Spec.ScalingConfiguration != nil && delta.DifferentAt("Spec.ScalingConfiguration") {
587+
if desired.ko.Spec.ScalingConfiguration != nil && delta.DifferentAt("Spec.ScalingConfiguration") {
586588
f22 := &svcsdk.ScalingConfiguration{}
587-
if r.ko.Spec.ScalingConfiguration.AutoPause != nil && delta.DifferentAt("Spec.ScalingConfiguration.AutoPause") {
588-
f22.SetAutoPause(*r.ko.Spec.ScalingConfiguration.AutoPause)
589+
if desired.ko.Spec.ScalingConfiguration.AutoPause != nil && delta.DifferentAt("Spec.ScalingConfiguration.AutoPause") {
590+
f22.SetAutoPause(*desired.ko.Spec.ScalingConfiguration.AutoPause)
589591
}
590-
if r.ko.Spec.ScalingConfiguration.MaxCapacity != nil && delta.DifferentAt("Spec.ScalingConfiguration.MaxCapacity") {
591-
f22.SetMaxCapacity(*r.ko.Spec.ScalingConfiguration.MaxCapacity)
592+
if desired.ko.Spec.ScalingConfiguration.MaxCapacity != nil && delta.DifferentAt("Spec.ScalingConfiguration.MaxCapacity") {
593+
f22.SetMaxCapacity(*desired.ko.Spec.ScalingConfiguration.MaxCapacity)
592594
}
593-
if r.ko.Spec.ScalingConfiguration.MinCapacity != nil && delta.DifferentAt("Spec.ScalingConfiguration.MinCapacity") {
594-
f22.SetMinCapacity(*r.ko.Spec.ScalingConfiguration.MinCapacity)
595+
if desired.ko.Spec.ScalingConfiguration.MinCapacity != nil && delta.DifferentAt("Spec.ScalingConfiguration.MinCapacity") {
596+
f22.SetMinCapacity(*desired.ko.Spec.ScalingConfiguration.MinCapacity)
595597
}
596-
if r.ko.Spec.ScalingConfiguration.SecondsUntilAutoPause != nil && delta.DifferentAt("Spec.ScalingConfiguration.SecondsUntilAutoPause") {
597-
f22.SetSecondsUntilAutoPause(*r.ko.Spec.ScalingConfiguration.SecondsUntilAutoPause)
598+
if desired.ko.Spec.ScalingConfiguration.SecondsUntilAutoPause != nil && delta.DifferentAt("Spec.ScalingConfiguration.SecondsUntilAutoPause") {
599+
f22.SetSecondsUntilAutoPause(*desired.ko.Spec.ScalingConfiguration.SecondsUntilAutoPause)
598600
}
599-
if r.ko.Spec.ScalingConfiguration.TimeoutAction != nil && delta.DifferentAt("Spec.ScalingConfiguration.TimeoutAction") {
600-
f22.SetTimeoutAction(*r.ko.Spec.ScalingConfiguration.TimeoutAction)
601+
if desired.ko.Spec.ScalingConfiguration.TimeoutAction != nil && delta.DifferentAt("Spec.ScalingConfiguration.TimeoutAction") {
602+
f22.SetTimeoutAction(*desired.ko.Spec.ScalingConfiguration.TimeoutAction)
601603
}
602604
res.SetScalingConfiguration(f22)
603605
}
604-
if r.ko.Spec.VPCSecurityGroupIDs != nil && delta.DifferentAt("Spec.VPCSecurityGroupIDs") {
606+
if desired.ko.Spec.VPCSecurityGroupIDs != nil && delta.DifferentAt("Spec.VPCSecurityGroupIDs") {
605607
f23 := []*string{}
606-
for _, f23iter := range r.ko.Spec.VPCSecurityGroupIDs {
608+
for _, f23iter := range desired.ko.Spec.VPCSecurityGroupIDs {
607609
var f23elem string
608610
f23elem = *f23iter
609611
f23 = append(f23, &f23elem)
610612
}
611613
res.SetVpcSecurityGroupIds(f23)
612614
}
613615
// For ServerlessV2ScalingConfiguration, MaxCapacity and MinCapacity, both need appear in modify call to get ServerlessV2ScalingConfiguration modified
614-
if r.ko.Spec.ServerlessV2ScalingConfiguration != nil && delta.DifferentAt("Spec.ServerlessV2ScalingConfiguration") {
616+
if desired.ko.Spec.ServerlessV2ScalingConfiguration != nil && delta.DifferentAt("Spec.ServerlessV2ScalingConfiguration") {
615617
f23 := &svcsdk.ServerlessV2ScalingConfiguration{}
616618
if delta.DifferentAt("Spec.ServerlessV2ScalingConfiguration.MaxCapacity") || delta.DifferentAt("Spec.ServerlessV2ScalingConfiguration.MinCapacity") {
617-
if r.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity != nil {
618-
f23.SetMaxCapacity(*r.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity)
619+
if desired.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity != nil {
620+
f23.SetMaxCapacity(*desired.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity)
619621
}
620-
if r.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity != nil {
621-
f23.SetMinCapacity(*r.ko.Spec.ServerlessV2ScalingConfiguration.MinCapacity)
622+
if desired.ko.Spec.ServerlessV2ScalingConfiguration.MaxCapacity != nil {
623+
f23.SetMinCapacity(*desired.ko.Spec.ServerlessV2ScalingConfiguration.MinCapacity)
622624
}
623625
}
624626
res.SetServerlessV2ScalingConfiguration(f23)
625627
}
628+
629+
if delta.DifferentAt("Spec.EnableCloudwatchLogsExports") {
630+
cloudwatchLogExportsConfigDesired := desired.ko.Spec.EnableCloudwatchLogsExports
631+
//Latest log types config
632+
cloudwatchLogExportsConfigLatest := latest.ko.Spec.EnableCloudwatchLogsExports
633+
logsTypesToEnable, logsTypesToDisable := getCloudwatchLogExportsConfigDifferences(cloudwatchLogExportsConfigDesired, cloudwatchLogExportsConfigLatest)
634+
f24 := &svcsdk.CloudwatchLogsExportConfiguration{
635+
EnableLogTypes: logsTypesToEnable,
636+
DisableLogTypes: logsTypesToDisable,
637+
}
638+
res.SetCloudwatchLogsExportConfiguration(f24)
639+
}
626640
return res, nil
627641
}
642+
643+
func getCloudwatchLogExportsConfigDifferences(cloudwatchLogExportsConfigDesired []*string, cloudwatchLogExportsConfigLatest []*string) ([]*string, []*string) {
644+
logsTypesToEnable := []*string{}
645+
logsTypesToDisable := []*string{}
646+
647+
for _, config := range cloudwatchLogExportsConfigDesired {
648+
if !slices.Contains(cloudwatchLogExportsConfigLatest, config) {
649+
logsTypesToEnable = append(logsTypesToEnable, config)
650+
}
651+
}
652+
for _, config := range cloudwatchLogExportsConfigLatest {
653+
if !slices.Contains(cloudwatchLogExportsConfigDesired, config) {
654+
logsTypesToDisable = append(logsTypesToDisable, config)
655+
}
656+
}
657+
return logsTypesToEnable, logsTypesToDisable
658+
}

‎pkg/resource/db_cluster/sdk.go

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎templates/hooks/db_cluster/sdk_read_many_post_set_output.go.tpl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,3 +36,5 @@
3636
// latest resource with the value from the status.
3737
ko.Spec.EnableIAMDatabaseAuthentication = ko.Status.IAMDatabaseAuthenticationEnabled
3838
}
39+
40+
ko.Spec.EnableCloudwatchLogsExports = ko.Status.EnabledCloudwatchLogsExports

‎test/e2e/resources/db_cluster_aurora_postgres_log_exports.yaml

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
apiVersion: rds.services.k8s.aws/v1alpha1
2+
kind: DBCluster
3+
metadata:
4+
name: $DB_CLUSTER_ID
5+
spec:
6+
autoMinorVersionUpgrade: false
7+
copyTagsToSnapshot: false
8+
dbClusterIdentifier: $DB_CLUSTER_ID
9+
enableIAMDatabaseAuthentication: false
10+
engine: aurora-postgresql
11+
enableCloudwatchLogsExports:
12+
- postgresql
13+
engineMode: provisioned
14+
engineVersion: "14.9"
15+
masterUsername: root
16+
masterUserPassword:
17+
namespace: $MASTER_USER_PASS_SECRET_NAMESPACE
18+
name: $MASTER_USER_PASS_SECRET_NAME
19+
key: $MASTER_USER_PASS_SECRET_KEY
20+
port: 5432
21+
storageEncrypted: true

‎test/e2e/tests/test_db_cluster.py

Lines changed: 101 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,12 +109,12 @@ def aurora_mysql_cluster(k8s_secret):
109109
db_cluster.wait_until_deleted(db_cluster_id)
110110

111111

112-
@pytest.fixture
112+
@pytest.fixture(scope="module")
113113
def aurora_postgres_cluster(k8s_secret):
114114
db_cluster_id = random_suffix_name("my-aurora-postgres", 20)
115115
secret = k8s_secret(
116116
MUP_NS,
117-
f"{MUP_SEC_NAME}-postgres",
117+
f"{MUP_SEC_NAME}-postgres-{db_cluster_id}",
118118
MUP_SEC_KEY,
119119
MUP_SEC_VAL,
120120
)
@@ -154,6 +154,50 @@ def aurora_postgres_cluster(k8s_secret):
154154

155155
db_cluster.wait_until_deleted(db_cluster_id)
156156

157+
@pytest.fixture(scope="module")
158+
def aurora_postgres_cluster_log_exports(k8s_secret):
159+
db_cluster_id = random_suffix_name("my-aurora-postgres-log-exports", 35)
160+
secret = k8s_secret(
161+
MUP_NS,
162+
f"{MUP_SEC_NAME}-postgres-{db_cluster_id}",
163+
MUP_SEC_KEY,
164+
MUP_SEC_VAL,
165+
)
166+
167+
resource_data = load_rds_resource(
168+
"db_cluster_aurora_postgres_log_exports",
169+
additional_replacements={
170+
"DB_CLUSTER_ID": db_cluster_id,
171+
"MASTER_USER_PASS_SECRET_NAMESPACE": secret.ns,
172+
"MASTER_USER_PASS_SECRET_NAME": secret.name,
173+
"MASTER_USER_PASS_SECRET_KEY": secret.key,
174+
},
175+
)
176+
177+
ref = k8s.CustomResourceReference(
178+
CRD_GROUP, CRD_VERSION, RESOURCE_PLURAL,
179+
db_cluster_id, namespace="default",
180+
)
181+
k8s.create_custom_resource(ref, resource_data)
182+
cr = k8s.wait_resource_consumed_by_controller(ref)
183+
184+
assert cr is not None
185+
assert 'status' in cr
186+
assert 'status' in cr['status']
187+
assert cr['status']['status'] == 'creating'
188+
condition.assert_not_synced(ref)
189+
190+
yield (ref, cr, db_cluster_id)
191+
192+
# Try to delete, if doesn't already exist
193+
try:
194+
_, deleted = k8s.delete_custom_resource(ref, 3, 10)
195+
assert deleted
196+
time.sleep(DELETE_WAIT_AFTER_SECONDS)
197+
except:
198+
pass
199+
200+
db_cluster.wait_until_deleted(db_cluster_id)
157201

158202
@service_marker
159203
@pytest.mark.canary
@@ -235,7 +279,6 @@ def test_flip_enable_iam_db_authn(
235279
self, aurora_postgres_cluster,
236280
):
237281
ref, _, db_cluster_id = aurora_postgres_cluster
238-
239282
db_cluster.wait_until(
240283
db_cluster_id,
241284
db_cluster.status_matches('available'),
@@ -257,3 +300,58 @@ def test_flip_enable_iam_db_authn(
257300
latest = db_cluster.get(db_cluster_id)
258301
assert latest is not None
259302
assert latest["IAMDatabaseAuthenticationEnabled"] == True
303+
304+
def test_enable_cloudwatch_logs_exports(
305+
self, aurora_postgres_cluster,
306+
):
307+
ref, _, db_cluster_id = aurora_postgres_cluster
308+
db_cluster.wait_until(
309+
db_cluster_id,
310+
db_cluster.status_matches('available'),
311+
)
312+
313+
current = db_cluster.get(db_cluster_id)
314+
assert current is not None
315+
enabledCloudwatchLogsExports = current.get("EnabledCloudwatchLogsExports",None)
316+
assert enabledCloudwatchLogsExports is None
317+
k8s.patch_custom_resource(
318+
ref,
319+
{"spec": {"enableCloudwatchLogsExports": ["postgresql"]}},
320+
)
321+
322+
db_cluster.wait_until(
323+
db_cluster_id,
324+
db_cluster.AttributeMatcher("EnabledCloudwatchLogsExports", ["postgresql"]),
325+
)
326+
327+
latest = db_cluster.get(db_cluster_id)
328+
assert latest is not None
329+
assert latest["EnabledCloudwatchLogsExports"] == ["postgresql"]
330+
331+
def test_disable_cloudwatch_logs_exports(
332+
self, aurora_postgres_cluster_log_exports,
333+
):
334+
ref, _, db_cluster_id = aurora_postgres_cluster_log_exports
335+
db_cluster.wait_until(
336+
db_cluster_id,
337+
db_cluster.status_matches('available'),
338+
)
339+
340+
current = db_cluster.get(db_cluster_id)
341+
assert current is not None
342+
enabledCloudwatchLogsExports = current.get("EnabledCloudwatchLogsExports",None)
343+
assert enabledCloudwatchLogsExports is not None
344+
k8s.patch_custom_resource(
345+
ref,
346+
{"spec": {"enableCloudwatchLogsExports": None}},
347+
)
348+
349+
db_cluster.wait_until(
350+
db_cluster_id,
351+
db_cluster.status_matches("available"),
352+
)
353+
354+
latest = db_cluster.get(db_cluster_id)
355+
assert latest is not None
356+
enabledCloudwatchLogsExportsLatest = latest.get("EnabledCloudwatchLogsExports",None)
357+
assert enabledCloudwatchLogsExportsLatest is None

0 commit comments

Comments
 (0)