This closes #3315
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e980ae92 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e980ae92 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e980ae92 Branch: refs/heads/master Commit: e980ae921f48b180ffb7fd7dba7eea10ef0f304a Parents: bc2f97c 7689e43 Author: [email protected] <[email protected]> Authored: Thu Jun 8 15:30:01 2017 -0700 Committer: [email protected] <[email protected]> Committed: Thu Jun 8 15:30:01 2017 -0700 ---------------------------------------------------------------------- .gitignore | 2 +- sdks/python/apache_beam/coders/coders.py | 2 +- sdks/python/apache_beam/pipeline.py | 4 ++-- sdks/python/apache_beam/portability/__init__.py | 18 +++++++++++++++++ .../apache_beam/portability/runners/__init__.py | 18 +++++++++++++++++ .../portability/runners/api/__init__.py | 21 ++++++++++++++++++++ sdks/python/apache_beam/pvalue.py | 2 +- sdks/python/apache_beam/runners/api/__init__.py | 21 -------------------- .../runners/dataflow/dataflow_runner.py | 4 ++-- .../apache_beam/runners/pipeline_context.py | 2 +- .../runners/portability/fn_api_runner.py | 2 +- .../apache_beam/runners/worker/data_plane.py | 2 +- .../runners/worker/data_plane_test.py | 2 +- .../apache_beam/runners/worker/log_handler.py | 2 +- .../runners/worker/log_handler_test.py | 2 +- .../apache_beam/runners/worker/sdk_worker.py | 2 +- .../runners/worker/sdk_worker_main.py | 2 +- .../runners/worker/sdk_worker_test.py | 2 +- sdks/python/apache_beam/transforms/core.py | 2 +- .../python/apache_beam/transforms/ptransform.py | 2 +- sdks/python/apache_beam/transforms/trigger.py | 2 +- sdks/python/apache_beam/transforms/window.py | 4 ++-- sdks/python/apache_beam/utils/urns.py | 2 +- sdks/python/gen_protos.py | 2 +- sdks/python/run_pylint.sh | 2 +- 25 files changed, 81 insertions(+), 45 deletions(-) ----------------------------------------------------------------------
