Closes #1762
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a7d349 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a7d349 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36a7d349 Branch: refs/heads/python-sdk Commit: 36a7d3491b4929f7539f2aa620b4ad25865036f6 Parents: f25c0e4 2197009 Author: Robert Bradshaw <[email protected]> Authored: Wed Jan 18 10:10:50 2017 -0800 Committer: Robert Bradshaw <[email protected]> Committed: Wed Jan 18 10:10:50 2017 -0800 ---------------------------------------------------------------------- .../examples/complete/autocomplete_test.py | 3 +- .../examples/complete/estimate_pi_test.py | 4 +- .../complete/juliaset/juliaset/juliaset.py | 2 +- .../complete/juliaset/juliaset/juliaset_test.py | 2 +- .../examples/complete/juliaset/juliaset_main.py | 2 +- .../apache_beam/examples/complete/tfidf.py | 3 +- .../apache_beam/examples/complete/tfidf_test.py | 3 +- .../examples/complete/top_wikipedia_sessions.py | 2 +- .../complete/top_wikipedia_sessions_test.py | 3 +- .../cookbook/bigquery_side_input_test.py | 3 +- .../cookbook/bigquery_tornadoes_test.py | 2 +- .../apache_beam/examples/cookbook/bigshuffle.py | 2 +- .../examples/cookbook/bigshuffle_test.py | 2 +- .../examples/cookbook/coders_test.py | 3 +- .../examples/cookbook/combiners_test.py | 5 +- .../examples/cookbook/custom_ptransform.py | 4 +- .../examples/cookbook/custom_ptransform_test.py | 3 +- .../examples/cookbook/datastore_wordcount.py | 7 +- .../examples/cookbook/filters_test.py | 3 +- .../examples/cookbook/group_with_coder.py | 2 +- .../examples/cookbook/group_with_coder_test.py | 4 +- .../examples/cookbook/mergecontacts.py | 2 +- .../examples/cookbook/mergecontacts_test.py | 3 +- .../examples/cookbook/multiple_output_pardo.py | 4 +- .../cookbook/multiple_output_pardo_test.py | 2 +- .../apache_beam/examples/snippets/snippets.py | 62 ++++++------- .../examples/snippets/snippets_test.py | 12 +-- .../apache_beam/examples/streaming_wordcap.py | 2 +- .../apache_beam/examples/streaming_wordcount.py | 2 +- sdks/python/apache_beam/examples/wordcount.py | 1 + .../apache_beam/examples/wordcount_debugging.py | 4 +- .../apache_beam/examples/wordcount_minimal.py | 4 +- .../python/apache_beam/io/concat_source_test.py | 3 +- .../apache_beam/io/filebasedsource_test.py | 19 ++-- sdks/python/apache_beam/io/fileio_test.py | 11 +-- sdks/python/apache_beam/io/sources_test.py | 3 +- sdks/python/apache_beam/io/textio_test.py | 26 +++--- sdks/python/apache_beam/pipeline.py | 2 +- sdks/python/apache_beam/pipeline_test.py | 13 +-- .../apache_beam/runners/dataflow_runner.py | 60 +++++++++---- .../apache_beam/runners/direct/direct_runner.py | 15 ++-- sdks/python/apache_beam/runners/runner.py | 35 +++++++- sdks/python/apache_beam/runners/runner_test.py | 1 + .../apache_beam/runners/template_runner_test.py | 4 +- .../runners/test/test_dataflow_runner.py | 4 +- sdks/python/apache_beam/test_pipeline.py | 11 ++- .../apache_beam/tests/pipeline_verifiers.py | 4 +- .../apache_beam/transforms/aggregator_test.py | 3 +- .../apache_beam/transforms/combiners_test.py | 26 +++--- .../python/apache_beam/transforms/ptransform.py | 2 +- .../apache_beam/transforms/ptransform_test.py | 93 ++++++++++---------- .../apache_beam/transforms/window_test.py | 10 +-- .../transforms/write_ptransform_test.py | 5 +- .../typehints/typed_pipeline_test.py | 6 +- .../apache_beam/utils/pipeline_options.py | 3 +- sdks/python/run_postcommit.sh | 2 +- sdks/python/tox.ini | 3 + 57 files changed, 304 insertions(+), 222 deletions(-) ----------------------------------------------------------------------
