You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2020/03/16 22:47:33 UTC
[beam] 02/02: [BEAM-9485] Raise error when transform urn is not
implemented
This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a commit to branch release-2.20.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 92706a9f5d8b9212c77da021561b843e9899d9a6
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Tue Mar 10 23:45:36 2020 -0700
[BEAM-9485] Raise error when transform urn is not implemented
---
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index ac39cb9..6e258d0 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -849,7 +849,8 @@ class DataflowRunner(PipelineRunner):
if common_urns.primitives.PAR_DO.urn == urn:
self.run_ParDo(transform_node, options)
else:
- NotImplementedError(urn)
+ raise NotImplementedError(
+ '%s uses unsupported URN: %s' % (transform_node.full_label, urn))
def run_ParDo(self, transform_node, options):
transform = transform_node.transform