This closes #2470
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7fd9c651 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7fd9c651 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7fd9c651 Branch: refs/heads/master Commit: 7fd9c6516e2222a5f3d290fd95507559b0c99940 Parents: 1761d1c 9e453fa Author: Ahmet Altay <al...@google.com> Authored: Mon Apr 10 15:28:12 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Mon Apr 10 15:28:12 2017 -0700 ---------------------------------------------------------------------- .../apache_beam/runners/direct/direct_runner.py | 18 ++--- sdks/python/apache_beam/runners/runner.py | 71 ++++++++++++-------- sdks/python/apache_beam/runners/runner_test.py | 41 +++++++++++ 3 files changed, 93 insertions(+), 37 deletions(-) ----------------------------------------------------------------------