[beam] branch master updated: [BEAM-9485] Raise error when transform urn is not implemented

[go...@apache.org]

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

goenka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 6df42b8  [BEAM-9485] Raise error when transform urn is not implemented
     new 64fb477  Merge pull request #11097 from angoenka/raise_non_implemented
6df42b8 is described below

commit 6df42b86e4aa2575ee51938133951a710788e09f
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 654ccfa..5965ba7 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -854,7 +854,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