(beam) branch liferoad-patch-1 created (now 3968f556ea5)

[xq...@apache.org]

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

xqhu pushed a change to branch liferoad-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git


      at 3968f556ea5 Update direct_runner.py

This branch includes the following new commits:

     new 3968f556ea5 Update direct_runner.py

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(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())