Closes #1802
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82599a24 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/82599a24 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/82599a24 Branch: refs/heads/python-sdk Commit: 82599a241454ba53640c0da4cae3f60ea7668e3e Parents: c57c66e 1ed81a2 Author: Robert Bradshaw <[email protected]> Authored: Fri Jan 20 16:46:22 2017 -0800 Committer: Robert Bradshaw <[email protected]> Committed: Fri Jan 20 16:46:22 2017 -0800 ---------------------------------------------------------------------- .../apache_beam/runners/dataflow_runner.py | 7 ++- .../apache_beam/runners/dataflow_runner_test.py | 64 ++++++++++++++++++++ sdks/python/apache_beam/test_pipeline.py | 5 +- .../apache_beam/transforms/aggregator_test.py | 2 +- 4 files changed, 75 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
