Closes #3847
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/28d4f098 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/28d4f098 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/28d4f098 Branch: refs/heads/master Commit: 28d4f0989de630c7e19b895a144a5fe1db706196 Parents: e7eefdd a1abccd Author: Robert Bradshaw <rober...@gmail.com> Authored: Tue Sep 19 15:20:24 2017 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Tue Sep 19 15:20:24 2017 -0700 ---------------------------------------------------------------------- .../runners/portability/fn_api_runner.py | 14 +- .../portability/universal_local_runner.py | 409 +++++++++++++++++++ .../portability/universal_local_runner_main.py | 44 ++ .../portability/universal_local_runner_test.py | 85 ++++ sdks/python/apache_beam/runners/runner.py | 1 + .../apache_beam/runners/worker/data_plane.py | 9 +- .../apache_beam/runners/worker/sdk_worker.py | 6 +- .../runners/worker/sdk_worker_main.py | 26 +- .../runners/worker/sdk_worker_test.py | 3 +- 9 files changed, 573 insertions(+), 24 deletions(-) ----------------------------------------------------------------------
