This closes #2051
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c3141ed9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c3141ed9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c3141ed9 Branch: refs/heads/master Commit: c3141ed99ec467dcf577a1ba9d46f80a694444db Parents: 2982238 22f3fb8 Author: Ahmet Altay <[email protected]> Authored: Tue Feb 21 16:04:47 2017 -0800 Committer: Ahmet Altay <[email protected]> Committed: Tue Feb 21 16:04:47 2017 -0800 ---------------------------------------------------------------------- .../examples/cookbook/datastore_wordcount.py | 4 +- .../examples/snippets/snippets_test.py | 18 +++ .../internal/google_cloud_platform/__init__.py | 16 ++ .../google_cloud_platform/json_value.py | 147 +++++++++++++++++++ .../google_cloud_platform/json_value_test.py | 93 ++++++++++++ sdks/python/apache_beam/internal/json_value.py | 141 ------------------ .../apache_beam/internal/json_value_test.py | 84 ----------- sdks/python/apache_beam/io/__init__.py | 11 +- sdks/python/apache_beam/io/fileio.py | 21 ++- .../io/google_cloud_platform/bigquery.py | 9 +- .../io/google_cloud_platform/bigquery_test.py | 19 ++- .../datastore/v1/datastoreio.py | 10 +- .../datastore/v1/datastoreio_test.py | 16 +- .../datastore/v1/fake_datastore.py | 10 +- .../datastore/v1/helper.py | 23 ++- .../datastore/v1/helper_test.py | 21 ++- .../datastore/v1/query_splitter.py | 26 ++-- .../datastore/v1/query_splitter_test.py | 17 ++- .../io/google_cloud_platform/gcsio_test.py | 12 +- .../internal/clients/bigquery/__init__.py | 12 +- .../internal/clients/storage/__init__.py | 12 +- sdks/python/apache_beam/runners/__init__.py | 5 +- .../google_cloud_dataflow/dataflow_runner.py | 2 +- .../dataflow_runner_test.py | 9 ++ .../google_cloud_dataflow/internal/apiclient.py | 2 +- .../internal/apiclient_test.py | 13 +- .../internal/clients/dataflow/__init__.py | 12 +- .../clients/dataflow/message_matchers_test.py | 14 +- .../template_runner_test.py | 13 +- .../test_dataflow_runner.py | 40 +++++ sdks/python/apache_beam/runners/runner_test.py | 31 ++-- .../python/apache_beam/runners/test/__init__.py | 8 +- .../runners/test/test_dataflow_runner.py | 40 ----- .../apache_beam/tests/pipeline_verifiers.py | 10 +- .../tests/pipeline_verifiers_test.py | 7 +- sdks/python/apache_beam/utils/retry.py | 13 +- sdks/python/apache_beam/utils/retry_test.py | 14 +- sdks/python/pom.xml | 2 +- sdks/python/setup.py | 20 ++- sdks/python/tox.ini | 37 ++++- 40 files changed, 643 insertions(+), 371 deletions(-) ----------------------------------------------------------------------
