This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-python-transforms
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-python-transforms by this
push:
new 8dcf9cce651 Use direct runner
8dcf9cce651 is described below
commit 8dcf9cce651853708b84cf74e3a24c148440d36c
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Tue Sep 2 12:34:55 2025 +0400
Use direct runner
---
sdks/python/apache_beam/transforms/external_test.py | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git a/sdks/python/apache_beam/transforms/external_test.py
b/sdks/python/apache_beam/transforms/external_test.py
index 6b7bac17f24..28e0bfbbf8f 100644
--- a/sdks/python/apache_beam/transforms/external_test.py
+++ b/sdks/python/apache_beam/transforms/external_test.py
@@ -349,7 +349,8 @@ class ExternalTransformTest(unittest.TestCase):
self.assertTrue(pipeline.contains_external_transforms)
def test_external_transform_finder_leaf(self):
- pipeline = beam.Pipeline()
+ opts = PipelineOptions(['--runner=DirectRunner'])
+ pipeline = beam.Pipeline(options=opts)
_ = (
pipeline
| beam.Create(['a', 'b'])
@@ -357,15 +358,10 @@ class ExternalTransformTest(unittest.TestCase):
'beam:transforms:xlang:test:nooutput',
ImplicitSchemaPayloadBuilder({'data': '0'}),
expansion_service.ExpansionServiceServicer()))
+ pipeline.run().wait_until_finish()
- # Force proto translation (triggers external expansion detection)
- _ = pipeline.to_runner_api()
-
- # Assert at build-time to avoid pruning effects.
self.assertTrue(pipeline.contains_external_transforms)
- pipeline.run().wait_until_finish()
-
def test_sanitize_java_traceback(self):
error_string = '''
java.lang.RuntimeException: ACTUAL \n MULTILINE \n ERROR
