This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new c6c815d3de3 added the rate test for GenerateSequence (#35108)
c6c815d3de3 is described below
commit c6c815d3de371b17dcc45c161c89ee68c2ad63b4
Author: liferoad <[email protected]>
AuthorDate: Mon Jun 2 16:00:28 2025 -0400
added the rate test for GenerateSequence (#35108)
* added the rate test for GenerateSequence
* keep the master yaml
---
.../transforms/external_transform_provider_it_test.py | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git
a/sdks/python/apache_beam/transforms/external_transform_provider_it_test.py
b/sdks/python/apache_beam/transforms/external_transform_provider_it_test.py
index d1c5cbfa8e9..5f115e6d44e 100644
--- a/sdks/python/apache_beam/transforms/external_transform_provider_it_test.py
+++ b/sdks/python/apache_beam/transforms/external_transform_provider_it_test.py
@@ -122,6 +122,18 @@ class ExternalTransformProviderIT(unittest.TestCase):
assert_that(numbers, equal_to([i for i in range(10)]))
+ def test_run_generate_sequence_with_rate(self):
+ provider = ExternalTransformProvider(
+ BeamJarExpansionService(":sdks:java:io:expansion-service:shadowJar"))
+
+ with beam.Pipeline() as p:
+ numbers = p | provider.GenerateSequence(
+ start=0, end=3, rate={
+ 'elements': 1, 'seconds': 1
+ }) | beam.Map(lambda row: row.value)
+
+ assert_that(numbers, equal_to([0, 1, 2]))
+
@pytest.mark.xlang_wrapper_generation
@unittest.skipUnless(
