Repository: incubator-beam Updated Branches: refs/heads/python-sdk 2f09003e3 -> adda16320
Changed ToStringCoder to BytesCoder in test The former can't be used with sources, as it can only encode. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/19a8407f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/19a8407f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/19a8407f Branch: refs/heads/python-sdk Commit: 19a8407f741848db0dc86e587ea9739b17888768 Parents: 2f09003 Author: Gus Katsiapis <katsia...@katsiapis-linux.mtv.corp.google.com> Authored: Mon Sep 19 17:21:45 2016 -0700 Committer: Robert Bradshaw <rober...@google.com> Committed: Mon Sep 19 17:53:44 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/sources_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/19a8407f/sdks/python/apache_beam/io/sources_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/sources_test.py b/sdks/python/apache_beam/io/sources_test.py index 45c5ab8..293f437 100644 --- a/sdks/python/apache_beam/io/sources_test.py +++ b/sdks/python/apache_beam/io/sources_test.py @@ -24,6 +24,7 @@ import unittest import apache_beam as beam +from apache_beam import coders from apache_beam.io import iobase from apache_beam.io import range_trackers from apache_beam.transforms.util import assert_that @@ -76,7 +77,7 @@ class LineSource(iobase.BoundedSource): return range_trackers.OffsetRangeTracker(start_position, stop_position) def default_output_coder(self): - return beam.coders.ToStringCoder() + return coders.BytesCoder() class SourcesTest(unittest.TestCase):
