This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 2ff4f0eda945ba076f7dd5be3cc7fe68cf317955
Merge: 67018be2650 661862a4ba2
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Fri Aug 21 10:01:47 2026 +0400

    Merge pull request #39763 from aIbrahiim/yaml-normalize-kinesis
    
    normalize KinesisIO

 .../KinesisReadSchemaTransformProvider.java        | 315 +++++++++++++++++++++
 .../KinesisWriteSchemaTransformProvider.java       | 280 ++++++++++++++++++
 .../KinesisSchemaTransformProviderTest.java        | 221 +++++++++++++++
 .../yaml/extended_tests/messaging/kinesis.yaml     |  83 ++++++
 sdks/python/apache_beam/yaml/integration_tests.py  | 107 +++++++
 sdks/python/apache_beam/yaml/standard_io.yaml      |  44 +++
 sdks/python/build.gradle                           |   1 +
 sdks/standard_external_transforms.yaml             | 134 ++++++++-
 8 files changed, 1184 insertions(+), 1 deletion(-)

diff --cc sdks/python/build.gradle
index 8568a07b44c,5e3ba546bc2..1a93983da66
--- a/sdks/python/build.gradle
+++ b/sdks/python/build.gradle
@@@ -172,9 -172,10 +172,10 @@@ tasks.register("postCommitYamlIntegrati
    dependsOn ":sdks:java:io:expansion-service:build"
    dependsOn ":sdks:java:io:google-cloud-platform:expansion-service:build"
    dependsOn ":sdks:java:io:debezium:expansion-service:shadowJar"
+   dependsOn ":sdks:java:io:amazon-web-services2:expansion-service:shadowJar"
  
    doLast {
 -    def testSetInput = project.findProperty('yamlTestSet') ?: 
'data,databases,messaging'
 +    def testSetInput = project.findProperty('yamlTestSet') ?: 
'data,databases,messaging,e2e'
      def testSetsToRun = testSetInput.tokenize(',').collect { it.trim() 
}.findAll { !it.isEmpty() }
      testSetsToRun.each { currentTestSet ->
        def test_files_dir

Reply via email to