This closes #1981
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/93ae666b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/93ae666b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/93ae666b Branch: refs/heads/master Commit: 93ae666bea01d4b90e2d6748b6139f34baee5111 Parents: 5fe11a2 75d5348 Author: Ahmet Altay <al...@google.com> Authored: Sun Feb 12 20:49:40 2017 -0800 Committer: Ahmet Altay <al...@google.com> Committed: Sun Feb 12 20:49:40 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/runner.py | 33 +++++++++++++++++---- sdks/python/apache_beam/runners/runner_test.py | 12 ++++++++ 2 files changed, 39 insertions(+), 6 deletions(-) ----------------------------------------------------------------------