This closes #3679
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b0b64218 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b0b64218 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b0b64218 Branch: refs/heads/master Commit: b0b64218257576ef20601fd31e075e4a8e297a60 Parents: 84a2379 1f2dddd Author: Ahmet Altay <al...@google.com> Authored: Sat Aug 12 18:06:21 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Sat Aug 12 18:06:21 2017 -0700 ---------------------------------------------------------------------- .../apache_beam/options/pipeline_options.py | 7 ++ sdks/python/apache_beam/pipeline_test.py | 30 ++++++ .../apache_beam/runners/direct/executor.py | 100 ++++++++++++------- 3 files changed, 100 insertions(+), 37 deletions(-) ----------------------------------------------------------------------