This closes #2665
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b8c568f2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b8c568f2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b8c568f2 Branch: refs/heads/master Commit: b8c568f2950d333f44b72b57c24f59464a0c9836 Parents: 0d69611 ad6dcf4 Author: Chamikara Jayalath <[email protected]> Authored: Tue Apr 25 16:22:26 2017 -0700 Committer: Chamikara Jayalath <[email protected]> Committed: Tue Apr 25 16:22:26 2017 -0700 ---------------------------------------------------------------------- sdks/python/.pylintrc | 1 + sdks/python/apache_beam/io/filebasedsource.py | 20 +- sdks/python/apache_beam/io/fileio.py | 25 +-- sdks/python/apache_beam/io/filesystem.py | 6 +- sdks/python/apache_beam/io/filesystems.py | 186 +++++++++++++++ sdks/python/apache_beam/io/filesystems_test.py | 224 +++++++++++++++++++ .../apache_beam/io/localfilesystem_test.py | 4 +- .../runners/dataflow/internal/apiclient.py | 7 +- .../runners/dataflow/internal/dependency.py | 32 ++- .../dataflow/internal/dependency_test.py | 7 +- .../apache_beam/tests/pipeline_verifiers.py | 7 +- 11 files changed, 452 insertions(+), 67 deletions(-) ----------------------------------------------------------------------
