fix: increate test wait time

Author: michaelhtm

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

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2025-04-01T02:35:33Z"
-  build_hash: 980cb1e4734f673d16101cf55206b84ca639ec01
+  build_date: "2025-04-08T22:25:51Z"
+  build_hash: 0909e7f0adb8ffe4120a8c20d5d58b991f2539e9
   go_version: go1.24.1
-  version: v0.44.0
+  version: v0.44.0-3-g0909e7f
 api_directory_checksum: 2f94829f12ad90f9c36c48823459c161c1670093
 api_version: v1alpha1
 aws_sdk_go_version: v1.32.6
 generator_config_info:
-  file_checksum: e7e79c3c7c21273967ca24947fda0f26b344c8f0
+  file_checksum: cc3489b53a45170d339a4de0d7d7ec0aa788955e
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

Diff for: apis/v1alpha1/generator.yaml

@@ -74,6 +74,8 @@ resources:
         from:
           operation: UpdateContributorInsights
           path: ContributorInsightsAction
+        compare: 
+          is_ignored: true
     exceptions:
       errors:
         404:

Diff for: generator.yaml

@@ -74,6 +74,8 @@ resources:
         from:
           operation: UpdateContributorInsights
           path: ContributorInsightsAction
+        compare: 
+          is_ignored: true
     exceptions:
       errors:
         404:

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

@@ -615,8 +615,16 @@ func customPreCompare(
 	// This will ensure controller does not act on this field
 	// if user is unaware of it.
 	if a.ko.Spec.ContributorInsights == nil {
-		a.ko.Spec.ContributorInsights = b.ko.Spec.ContributorInsights
+		return
 	}
+	// latestInsight will always be either ENABLED or DISABLED, since we requeue at readOne if its not 
+	// either
+	desiredInsight, _ := prepareContibutorInsight(a)
+	latestInsight, _ := prepareContibutorInsight(b)
+	if desiredInsight != latestInsight {
+		delta.Add("Spec.ContributorInsights", a.ko.Spec.ContributorInsights, b.ko.Spec.ContributorInsights)
+	}
+
 }
 
 // equalAttributeDefinitions return whether two AttributeDefinition arrays are equal or not.
@@ -774,41 +782,18 @@ func (rm *resourceManager) setContributorInsights(
 	if err != nil {
 		return err
 	}
-	
-	// This portion is needed if we want to have a smooth delta comparison
-	// If the name ends in ED (ENABLED, DISABLED) just assign the value
-	endsWithED := false
+
+	// Only manage ContributorInsights if it is defined
 	if ko.Spec.ContributorInsights != nil {
-		endsWithED = strings.HasSuffix(*ko.Spec.TableName, "ED")
-	}
-	if endsWithED {
 		ko.Spec.ContributorInsights = aws.String(string(resp.ContributorInsightsStatus))
-		return nil
-	}
-	// if not do the conversion
-	switch resp.ContributorInsightsStatus {
-	case svcsdktypes.ContributorInsightsStatusEnabled:
-		ko.Spec.ContributorInsights = aws.String(string(svcsdktypes.ContributorInsightsActionEnable))
-	case svcsdktypes.ContributorInsightsStatusDisabled:
-		ko.Spec.ContributorInsights = aws.String(string(svcsdktypes.ContributorInsightsActionDisable))
-	default:
-		ko.Spec.ContributorInsights = aws.String(string(resp.ContributorInsightsStatus))
-
 	}
 
 	return nil
 }
 
-func (rm *resourceManager) updateContributorInsights(
-	ctx context.Context,
-	r *resource,
-) (err error) {
-	rlog := ackrtlog.FromContext(ctx)
-	exit := rlog.Trace("rm.updateCloudformationInsights")
-	defer func() {
-		exit(err)
-	}()
-
+// prepareContributorInsight ensures the controller understands ENABLE and ENABLED are the same.
+// We choose to return ContributorInsightsAction because that is the enum used to update.
+func prepareContibutorInsight(r *resource) (svcsdktypes.ContributorInsightsAction, error) {
 	insight := svcsdktypes.ContributorInsightsActionDisable
 	if r.ko.Spec.ContributorInsights != nil {
 		// We will allow users to provide values ENABLE, ENABLED, DISABLE, DISABLED
@@ -818,10 +803,28 @@ func (rm *resourceManager) updateContributorInsights(
 		case string(svcsdktypes.ContributorInsightsActionDisable), string(svcsdktypes.ContributorInsightsStatusDisabled):
 			insight = svcsdktypes.ContributorInsightsActionDisable
 		default:
-			return fmt.Errorf("invalid ContributorInsights value: %s", *r.ko.Spec.ContributorInsights)
+			return "", fmt.Errorf("invalid ContributorInsights value: %s", *r.ko.Spec.ContributorInsights)
 		}
 	}
 
+	return insight, nil
+}
+
+func (rm *resourceManager) updateContributorInsights(
+	ctx context.Context,
+	r *resource,
+) (err error) {
+	rlog := ackrtlog.FromContext(ctx)
+	exit := rlog.Trace("rm.updateCloudformationInsights")
+	defer func() {
+		exit(err)
+	}()
+
+	insight, err := prepareContibutorInsight(r)
+	if err != nil {
+		return fmt.Errorf("failed preparing contributorInsight: %v", err)
+	}
+
 	_, err = rm.sdkapi.UpdateContributorInsights(
 		ctx,
 		&svcsdk.UpdateContributorInsightsInput{

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

@@ -7,7 +7,7 @@ spec:
   tableName: $TABLE_NAME
   billingMode: PAY_PER_REQUEST
   tableClass: STANDARD
-  contributorInsights: ENABLE
+  contributorInsights: ENABLED
   attributeDefinitions:
     - attributeName: Bill
       attributeType: S

Diff for: test/e2e/resources/table_insights.yaml

@@ -279,6 +279,8 @@ def test_enable_ttl(self, table_lsi):
         # Patch k8s resource
         k8s.patch_custom_resource(ref, updates)
 
+        time.sleep(MODIFY_WAIT_AFTER_SECONDS)
+
         table.wait_until(
             table_name,
             table.ttl_on_attribute_matches("ForumName"),
@@ -480,7 +482,7 @@ def test_update_insights(self, table_insights):
 
         # Check DynamoDB Table exists
         assert self.table_exists(table_name)
-        assert cr['spec']['contributorInsights'] == "ENABLE"
+        assert cr['spec']['contributorInsights'] == "ENABLED"
         assert self.table_insight_status(table_name, "ENABLED")
 
         # Set provisionedThroughput