This is an automated email from the ASF dual-hosted git repository. xqhu pushed a commit to branch liferoad-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3968f556ea5bd2055d3d1e92c4c5fce6217dca0b Author: liferoad <[email protected]> AuthorDate: Tue Aug 27 08:53:09 2024 -0400 Update direct_runner.py Improve the error message for DirectRunner. --- sdks/python/apache_beam/runners/direct/direct_runner.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py index 1cd20550edf..58aa338ac6a 100644 --- a/sdks/python/apache_beam/runners/direct/direct_runner.py +++ b/sdks/python/apache_beam/runners/direct/direct_runner.py @@ -516,7 +516,8 @@ class BundleBasedDirectRunner(PipelineRunner): if isinstance(applied_ptransform.transform, ExternalTransform): raise RuntimeError( "Streaming Python direct runner " - "does not support cross-language pipelines.") + "does not support cross-language pipelines." + "Please use other runners such as DataflowRunner.") pipeline.visit(VerifyNoCrossLanguageTransforms())
