This closes #2026
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36ed3f6c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36ed3f6c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36ed3f6c Branch: refs/heads/master Commit: 36ed3f6c54d35ac48241789fd77e2657d54c5831 Parents: 9df1da4 4337c3e Author: Ahmet Altay <[email protected]> Authored: Thu Feb 16 23:09:06 2017 -0800 Committer: Ahmet Altay <[email protected]> Committed: Thu Feb 16 23:09:06 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/internal/apiclient.py | 726 --- .../apache_beam/internal/apiclient_test.py | 87 - .../internal/clients/dataflow/__init__.py | 27 - .../clients/dataflow/dataflow_v1b3_client.py | 683 --- .../clients/dataflow/dataflow_v1b3_messages.py | 4173 ------------------ .../clients/dataflow/message_matchers.py | 124 - .../clients/dataflow/message_matchers_test.py | 69 - .../google_cloud_dataflow/dataflow_runner.py | 8 +- .../dataflow_runner_test.py | 2 +- .../google_cloud_dataflow/internal/__init__.py | 16 + .../google_cloud_dataflow/internal/apiclient.py | 726 +++ .../internal/apiclient_test.py | 87 + .../internal/clients/__init__.py | 16 + .../internal/clients/dataflow/__init__.py | 27 + .../clients/dataflow/dataflow_v1b3_client.py | 684 +++ .../clients/dataflow/dataflow_v1b3_messages.py | 4173 ++++++++++++++++++ .../clients/dataflow/message_matchers.py | 124 + .../clients/dataflow/message_matchers_test.py | 69 + .../template_runner_test.py | 88 + sdks/python/apache_beam/runners/runner_test.py | 20 +- .../apache_beam/runners/template_runner_test.py | 88 - 21 files changed, 6024 insertions(+), 5993 deletions(-) ----------------------------------------------------------------------
