Post-merge fixup.

Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb57b974
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb57b974
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/eb57b974

Branch: refs/heads/python-sdk
Commit: eb57b974c1ca9d231e614debaf40f686da9e4e02
Parents: 46110e4
Author: Robert Bradshaw <rober...@google.com>
Authored: Tue Oct 11 11:23:27 2016 -0700
Committer: Robert Bradshaw <rober...@google.com>
Committed: Tue Oct 11 11:23:27 2016 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/io/fileio_test.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/eb57b974/sdks/python/apache_beam/io/fileio_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/fileio_test.py 
b/sdks/python/apache_beam/io/fileio_test.py
index 42ea9ff..45435e6 100644
--- a/sdks/python/apache_beam/io/fileio_test.py
+++ b/sdks/python/apache_beam/io/fileio_test.py
@@ -466,8 +466,8 @@ class TestTextFileSource(unittest.TestCase):
       for percent_complete in percents_complete:
         self.try_splitting_reader_at(
             reader,
-            iobase.DynamicSplitRequest(
-                iobase.ReaderProgress(percent_complete=percent_complete)),
+            dataflow_io.DynamicSplitRequest(
+                dataflow_io.ReaderProgress(percent_complete=percent_complete)),
             None)
 
       # Cursor passed beginning of file.
@@ -477,8 +477,8 @@ class TestTextFileSource(unittest.TestCase):
       for percent_complete in percents_complete:
         self.try_splitting_reader_at(
             reader,
-            iobase.DynamicSplitRequest(
-                iobase.ReaderProgress(percent_complete=percent_complete)),
+            dataflow_io.DynamicSplitRequest(
+                dataflow_io.ReaderProgress(percent_complete=percent_complete)),
             None)
 
   def test_zlib_file_unsplittable(self):

Reply via email to