This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit ba62679f9ebd9266f6cbea84aa1196cfac30d451
Merge: 6411964 f320645
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Thu Jun 14 17:51:16 2018 -0700
Merge pull request #5393 Improve the TaggedOutput error
Improve the TaggedOutput error when a tuple is passed as a tag.
sdks/python/apache_beam/pvalue.py | 2 +-
sdks/python/apache_beam/pvalue_test.py | 10 ++++++++++
2 files changed, 11 insertions(+), 1 deletion(-)
diff --cc sdks/python/apache_beam/pvalue.py
index 3201249,4064d5b..5668b9a
--- a/sdks/python/apache_beam/pvalue.py
+++ b/sdks/python/apache_beam/pvalue.py
@@@ -266,9 -261,9 +266,9 @@@ class TaggedOutput(object)
"""
def __init__(self, tag, value):
- if not isinstance(tag, string_types):
+ if not isinstance(tag, (str, unicode)):
raise TypeError(
- 'Attempting to create a TaggedOutput with non-string tag %s' % tag)
+ 'Attempting to create a TaggedOutput with non-string tag %s' %
(tag,))
self.tag = tag
self.value = value
--
To stop receiving notification emails like this one, please contact
rober...@apache.org.
