You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/08/21 06:01:58 UTC
(beam) 01/01: Merge pull request #39763 from aIbrahiim/yaml-normalize-kinesis
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 <vi...@gmail.com>
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