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 <[email protected]> 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
