[beam] branch master updated: [BEAM-7988] py: include runner name when runner is invalid

[goenka]

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 1041db2  [BEAM-7988] py: include runner name when runner is invalid
     new 862b04c  Merge pull request #9355 from ibzib/bad-runner
1041db2 is described below

commit 1041db2c300aab7e94e7a008b71ea1a091045f9a
Author: Kyle Weaver <kcwea...@google.com>
AuthorDate: Thu Aug 15 17:24:30 2019 -0700

    [BEAM-7988] py: include runner name when runner is invalid
---
 sdks/python/apache_beam/pipeline.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/pipeline.py 
b/sdks/python/apache_beam/pipeline.py
index 25f9a1f..2a3c6a7 100644
--- a/sdks/python/apache_beam/pipeline.py
+++ b/sdks/python/apache_beam/pipeline.py
@@ -145,8 +145,8 @@ class Pipeline(object):
     if isinstance(runner, str):
       runner = create_runner(runner)
     elif not isinstance(runner, PipelineRunner):
-      raise TypeError('Runner must be a PipelineRunner object or the '
-                      'name of a registered runner.')
+      raise TypeError('Runner %s is not a PipelineRunner object or the '
+                      'name of a registered runner.' % runner)
 
     # Validate pipeline options
     errors = PipelineOptionsValidator(self._options, runner).validate()