Update direct_runner.py (#32325)

* Update direct_runner.py Improve the error message for DirectRunner. * Update direct_runner.py
apache · Oct 2, 2024 · 9095547 · 9095547
1 parent bb09de7
commit 9095547
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py
@@ -516,7 +516,9 @@ def visit_transform(self, applied_ptransform):
         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 FlinkRunner, "
+              "DataflowRunner, or PrismRunner.")
 
     pipeline.visit(VerifyNoCrossLanguageTransforms())