robertwb commented on code in PR #29481:
URL: https://github.com/apache/beam/pull/29481#discussion_r1416285850
##########
sdks/python/apache_beam/runners/direct/direct_runner.py:
##########
@@ -507,6 +507,17 @@ def run_pipeline(self, pipeline, options):
from apache_beam.runners.direct.transform_evaluator import \
TransformEvaluatorRegistry
from apache_beam.testing.test_stream import TestStream
+ from apache_beam.transforms.external import ExternalTransform
+
+ class VerifyNoCrossLanguageTransforms(PipelineVisitor):
+ """Visitor determining whether a Pipeline uses a TestStream."""
+ def visit_transform(self, applied_ptransform):
+ if isinstance(applied_ptransform.transform, ExternalTransform):
+ raise RuntimeError(
+ "Streaming Python direct runner "
+ "does not support cross-language pipelines.")
Review Comment:
https://issues.apache.org/jira/browse/BEAM-7514 is probably the closest we
have.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
