Closes #2801
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/30e61164 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/30e61164 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/30e61164 Branch: refs/heads/master Commit: 30e611646c7278d2439b02471a388843ad87ebde Parents: 3bb0f8e 444da27 Author: Robert Bradshaw <rober...@gmail.com> Authored: Tue May 2 17:37:12 2017 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Tue May 2 17:37:12 2017 -0700 ---------------------------------------------------------------------- .../examples/snippets/snippets_test.py | 11 +- sdks/python/apache_beam/pipeline.py | 25 +++-- sdks/python/apache_beam/pipeline_test.py | 2 +- .../runners/dataflow/dataflow_runner.py | 7 +- .../runners/dataflow/dataflow_runner_test.py | 4 +- .../runners/dataflow/template_runner_test.py | 2 +- .../runners/dataflow/test_dataflow_runner.py | 4 +- .../apache_beam/runners/direct/direct_runner.py | 4 +- sdks/python/apache_beam/transforms/core.py | 2 +- .../apache_beam/transforms/ptransform_test.py | 102 +++++++++---------- 10 files changed, 84 insertions(+), 79 deletions(-) ----------------------------------------------------------------------