Adding e2e tests for ScalingConfig

Vandita2020 · Vandita2020 · commit 21c47d8169a7 · 2023-01-30T16:19:40.000-08:00
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)`