Adding e2e tests for ScalingConfig

Vandita2020 · Vandita2020 · commit bac64cf35e71 · 2023-01-31T16:42:16.000-08:00
diff --git a/apis/v1alpha1/ack-generate-metadata.yaml b/apis/v1alpha1/ack-generate-metadata.yaml
@@ -1,5 +1,5 @@
 ack_generate_info:
-  build_date: "2023-01-29T21:40:15Z"
+  build_date: "2023-02-01T00:38:06Z"
   build_hash: 12246c7da82841b351ec7a9e1f139f9338f2784b
   go_version: go1.19
   version: v0.20.1-14-g12246c7
diff --git a/test/e2e/tests/test_event_source_mapping.py b/test/e2e/tests/test_event_source_mapping.py
@@ -128,6 +128,7 @@ def test_smoke_sqs_queue_stream(self, lambda_client, lambda_function):
                 },
             ]
         }
+        cr["spec"]["scalingConfig"] = {"maximumConcurrency": 4}
 
         # Patch k8s resource
         k8s.patch_custom_resource(ref, cr)
@@ -142,6 +143,7 @@ def test_smoke_sqs_queue_stream(self, lambda_client, lambda_function):
                 "Pattern": "{\"controller-version\":[\"v1\"]}"
             },
         ]
+        assert esm["ScalingConfig"]["MaximumConcurrency"] == 4
 
         # Delete the filterCriteria field
         cr = k8s.wait_resource_consumed_by_controller(ref)

Original file line number	Diff line number	Diff line change
`@@ -128,6 +128,7 @@ def test_smoke_sqs_queue_stream(self, lambda_client, lambda_function):`
`128`	`128`	`},`
`129`	`129`	`]`
`130`	`130`	`}`
	`131`	`+ cr["spec"]["scalingConfig"] = {"maximumConcurrency": 4}`
`131`	`132`
`132`	`133`	`# Patch k8s resource`
`133`	`134`	`k8s.patch_custom_resource(ref, cr)`
`@@ -142,6 +143,7 @@ def test_smoke_sqs_queue_stream(self, lambda_client, lambda_function):`
`142`	`143`	`"Pattern": "{\"controller-version\":[\"v1\"]}"`
`143`	`144`	`},`
`144`	`145`	`]`
	`146`	`+ assert esm["ScalingConfig"]["MaximumConcurrency"] == 4`
`145`	`147`
`146`	`148`	`# Delete the filterCriteria field`
`147`	`149`	`cr = k8s.wait_resource_consumed_by_controller(ref)`