This closes #3370
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/54f30789 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/54f30789 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/54f30789 Branch: refs/heads/master Commit: 54f30789165a49d92479b54cf3dac9d4a063e366 Parents: f2a32b2 5aee624 Author: Ahmet Altay <al...@google.com> Authored: Fri Jun 16 09:57:16 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Fri Jun 16 09:57:16 2017 -0700 ---------------------------------------------------------------------- .../runners/direct/bundle_factory.py | 2 +- .../apache_beam/runners/direct/executor.py | 64 ++++++++++++-------- .../runners/direct/transform_evaluator.py | 39 +++++++++++- 3 files changed, 77 insertions(+), 28 deletions(-) ----------------------------------------------------------------------
