(beam) 01/01: Update direct_runner.py

[xq...@apache.org]

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 <hu...@gmail.com>
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())