This is an automated email from the ASF dual-hosted git repository.
riteshghorse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new cc2e63ea75a [RRIO][Python] Add python grpc binding for mock API
(#29129)
cc2e63ea75a is described below
commit cc2e63ea75a6ff31fc6c97c5feb63191e81ebf53
Author: Ritesh Ghorse <riteshgho...@gmail.com>
AuthorDate: Fri Nov 3 14:54:54 2023 -0400
[RRIO][Python] Add python grpc binding for mock API (#29129)
* add python grpc binding for mock api
* add licenses
* update python version for buf plugin
* add poetry for python dependencies
* add license
* del author,desc
* update package for pyproject
* update python path
---
.test-infra/mock-apis/README.md | 1 +
.test-infra/mock-apis/buf.gen.yaml | 6 +-
.test-infra/mock-apis/poetry.lock | 236 +++++++++++++++++++++
.test-infra/mock-apis/pyproject.toml | 38 ++++
.../src/main/python/proto/echo/v1/echo_pb2.py | 47 ++++
.../src/main/python/proto/echo/v1/echo_pb2_grpc.py | 87 ++++++++
6 files changed, 414 insertions(+), 1 deletion(-)
diff --git a/.test-infra/mock-apis/README.md b/.test-infra/mock-apis/README.md
index 9c4911a0d63..ec94eb45a19 100644
--- a/.test-infra/mock-apis/README.md
+++ b/.test-infra/mock-apis/README.md
@@ -62,6 +62,7 @@ TODO: See https://github.com/apache/beam/issues/28859
| [go](https://go.dev) | For making code
changes in this directory. See [go.mod](go.mod) for required version. |
| [buf](https://github.com/bufbuild/buf#installation) | Optional for when
making changes to proto. |
| [ko](https://ko.build/install/) | To easily build Go
container images. |
+| [poetry](https://python-poetry.org/) | To manage python
dependencies. |
# Testing
diff --git a/.test-infra/mock-apis/buf.gen.yaml
b/.test-infra/mock-apis/buf.gen.yaml
index 31e57ff2da1..e5f6e51c14d 100644
--- a/.test-infra/mock-apis/buf.gen.yaml
+++ b/.test-infra/mock-apis/buf.gen.yaml
@@ -37,4 +37,8 @@ plugins:
- name: java
out: src/main/java
- name: grpc-java
- out: src/main/java
\ No newline at end of file
+ out: src/main/java
+- plugin: buf.build/protocolbuffers/python:v24.4
+ out: src/main/python
+- plugin: buf.build/grpc/python:v1.59.1
+ out: src/main/python
\ No newline at end of file
diff --git a/.test-infra/mock-apis/poetry.lock
b/.test-infra/mock-apis/poetry.lock
new file mode 100644
index 00000000000..e9bcdbb4750
--- /dev/null
+++ b/.test-infra/mock-apis/poetry.lock
@@ -0,0 +1,236 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+# This file is automatically @generated by Poetry 1.7.0 and should not be
changed by hand.
+
+[[package]]
+name = "beautifulsoup4"
+version = "4.12.2"
+description = "Screen-scraping library"
+optional = false
+python-versions = ">=3.6.0"
+files = [
+ {file = "beautifulsoup4-4.12.2-py3-none-any.whl", hash =
"sha256:bd2520ca0d9d7d12694a53d44ac482d181b4ec1888909b035a3dbf40d0f57d4a"},
+ {file = "beautifulsoup4-4.12.2.tar.gz", hash =
"sha256:492bbc69dca35d12daac71c4db1bfff0c876c00ef4a2ffacce226d4638eb72da"},
+]
+
+[package.dependencies]
+soupsieve = ">1.2"
+
+[package.extras]
+html5lib = ["html5lib"]
+lxml = ["lxml"]
+
+[[package]]
+name = "google"
+version = "3.0.0"
+description = "Python bindings to the Google search engine."
+optional = false
+python-versions = "*"
+files = [
+ {file = "google-3.0.0-py2.py3-none-any.whl", hash =
"sha256:889cf695f84e4ae2c55fbc0cfdaf4c1e729417fa52ab1db0485202ba173e4935"},
+ {file = "google-3.0.0.tar.gz", hash =
"sha256:143530122ee5130509ad5e989f0512f7cb218b2d4eddbafbad40fd10e8d8ccbe"},
+]
+
+[package.dependencies]
+beautifulsoup4 = "*"
+
+[[package]]
+name = "grpcio"
+version = "1.59.2"
+description = "HTTP/2-based RPC framework"
+optional = false
+python-versions = ">=3.7"
+files = [
+ {file = "grpcio-1.59.2-cp310-cp310-linux_armv7l.whl", hash =
"sha256:d2fa68a96a30dd240be80bbad838a0ac81a61770611ff7952b889485970c4c71"},
+ {file = "grpcio-1.59.2-cp310-cp310-macosx_12_0_universal2.whl", hash =
"sha256:cf0dead5a2c5a3347af2cfec7131d4f2a2e03c934af28989c9078f8241a491fa"},
+ {file = "grpcio-1.59.2-cp310-cp310-manylinux_2_17_aarch64.whl", hash =
"sha256:e420ced29b5904cdf9ee5545e23f9406189d8acb6750916c2db4793dada065c6"},
+ {file =
"grpcio-1.59.2-cp310-cp310-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:2b230028a008ae1d0f430acb227d323ff8a619017415cf334c38b457f814119f"},
+ {file =
"grpcio-1.59.2-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:0a4a3833c0e067f3558538727235cd8a49709bff1003200bbdefa2f09334e4b1"},
+ {file = "grpcio-1.59.2-cp310-cp310-musllinux_1_1_i686.whl", hash =
"sha256:6b25ed37c27e652db01be341af93fbcea03d296c024d8a0e680017a268eb85dd"},
+ {file = "grpcio-1.59.2-cp310-cp310-musllinux_1_1_x86_64.whl", hash =
"sha256:73abb8584b0cf74d37f5ef61c10722adc7275502ab71789a8fe3cb7ef04cf6e2"},
+ {file = "grpcio-1.59.2-cp310-cp310-win32.whl", hash =
"sha256:d6f70406695e3220f09cd7a2f879333279d91aa4a8a1d34303b56d61a8180137"},
+ {file = "grpcio-1.59.2-cp310-cp310-win_amd64.whl", hash =
"sha256:3c61d641d4f409c5ae46bfdd89ea42ce5ea233dcf69e74ce9ba32b503c727e29"},
+ {file = "grpcio-1.59.2-cp311-cp311-linux_armv7l.whl", hash =
"sha256:3059668df17627f0e0fa680e9ef8c995c946c792612e9518f5cc1503be14e90b"},
+ {file = "grpcio-1.59.2-cp311-cp311-macosx_10_10_universal2.whl", hash =
"sha256:72ca2399097c0b758198f2ff30f7178d680de8a5cfcf3d9b73a63cf87455532e"},
+ {file = "grpcio-1.59.2-cp311-cp311-manylinux_2_17_aarch64.whl", hash =
"sha256:c978f864b35f2261e0819f5cd88b9830b04dc51bcf055aac3c601e525a10d2ba"},
+ {file =
"grpcio-1.59.2-cp311-cp311-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:9411e24328a2302e279e70cae6e479f1fddde79629fcb14e03e6d94b3956eabf"},
+ {file =
"grpcio-1.59.2-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:bb7e0fe6ad73b7f06d7e2b689c19a71cf5cc48f0c2bf8608469e51ffe0bd2867"},
+ {file = "grpcio-1.59.2-cp311-cp311-musllinux_1_1_i686.whl", hash =
"sha256:c2504eed520958a5b77cc99458297cb7906308cb92327f35fb7fbbad4e9b2188"},
+ {file = "grpcio-1.59.2-cp311-cp311-musllinux_1_1_x86_64.whl", hash =
"sha256:2171c39f355ba5b551c5d5928d65aa6c69807fae195b86ef4a7d125bcdb860a9"},
+ {file = "grpcio-1.59.2-cp311-cp311-win32.whl", hash =
"sha256:d2794f0e68b3085d99b4f6ff9c089f6fdd02b32b9d3efdfbb55beac1bf22d516"},
+ {file = "grpcio-1.59.2-cp311-cp311-win_amd64.whl", hash =
"sha256:2067274c88bc6de89c278a672a652b4247d088811ece781a4858b09bdf8448e3"},
+ {file = "grpcio-1.59.2-cp312-cp312-linux_armv7l.whl", hash =
"sha256:535561990e075fa6bd4b16c4c3c1096b9581b7bb35d96fac4650f1181e428268"},
+ {file = "grpcio-1.59.2-cp312-cp312-macosx_10_10_universal2.whl", hash =
"sha256:a213acfbf186b9f35803b52e4ca9addb153fc0b67f82a48f961be7000ecf6721"},
+ {file = "grpcio-1.59.2-cp312-cp312-manylinux_2_17_aarch64.whl", hash =
"sha256:6959fb07e8351e20501ffb8cc4074c39a0b7ef123e1c850a7f8f3afdc3a3da01"},
+ {file =
"grpcio-1.59.2-cp312-cp312-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:e82c5cf1495244adf5252f925ac5932e5fd288b3e5ab6b70bec5593074b7236c"},
+ {file =
"grpcio-1.59.2-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:023088764012411affe7db183d1ada3ad9daf2e23ddc719ff46d7061de661340"},
+ {file = "grpcio-1.59.2-cp312-cp312-musllinux_1_1_i686.whl", hash =
"sha256:da2d94c15f88cd40d7e67f7919d4f60110d2b9d5b1e08cf354c2be773ab13479"},
+ {file = "grpcio-1.59.2-cp312-cp312-musllinux_1_1_x86_64.whl", hash =
"sha256:6009386a2df66159f64ac9f20425ae25229b29b9dd0e1d3dd60043f037e2ad7e"},
+ {file = "grpcio-1.59.2-cp312-cp312-win32.whl", hash =
"sha256:75c6ecb70e809cf1504465174343113f51f24bc61e22a80ae1c859f3f7034c6d"},
+ {file = "grpcio-1.59.2-cp312-cp312-win_amd64.whl", hash =
"sha256:cbe946b3e6e60a7b4618f091e62a029cb082b109a9d6b53962dd305087c6e4fd"},
+ {file = "grpcio-1.59.2-cp37-cp37m-linux_armv7l.whl", hash =
"sha256:f8753a6c88d1d0ba64302309eecf20f70d2770f65ca02d83c2452279085bfcd3"},
+ {file = "grpcio-1.59.2-cp37-cp37m-macosx_10_10_universal2.whl", hash =
"sha256:f1ef0d39bc1feb420caf549b3c657c871cad4ebbcf0580c4d03816b0590de0cf"},
+ {file = "grpcio-1.59.2-cp37-cp37m-manylinux_2_17_aarch64.whl", hash =
"sha256:4c93f4abbb54321ee6471e04a00139c80c754eda51064187963ddf98f5cf36a4"},
+ {file =
"grpcio-1.59.2-cp37-cp37m-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:08d77e682f2bf730a4961eea330e56d2f423c6a9b91ca222e5b1eb24a357b19f"},
+ {file =
"grpcio-1.59.2-cp37-cp37m-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash
= "sha256:1ff16d68bf453275466a9a46739061a63584d92f18a0f5b33d19fc97eb69867c"},
+ {file = "grpcio-1.59.2-cp37-cp37m-musllinux_1_1_i686.whl", hash =
"sha256:4abb717e320e74959517dc8e84a9f48fbe90e9abe19c248541e9418b1ce60acd"},
+ {file = "grpcio-1.59.2-cp37-cp37m-musllinux_1_1_x86_64.whl", hash =
"sha256:36f53c2b3449c015880e7d55a89c992c357f176327b0d2873cdaaf9628a37c69"},
+ {file = "grpcio-1.59.2-cp37-cp37m-win_amd64.whl", hash =
"sha256:cc3e4cd087f07758b16bef8f31d88dbb1b5da5671d2f03685ab52dece3d7a16e"},
+ {file = "grpcio-1.59.2-cp38-cp38-linux_armv7l.whl", hash =
"sha256:27f879ae604a7fcf371e59fba6f3ff4635a4c2a64768bd83ff0cac503142fef4"},
+ {file = "grpcio-1.59.2-cp38-cp38-macosx_10_10_universal2.whl", hash =
"sha256:7cf05053242f61ba94014dd3a986e11a083400a32664058f80bf4cf817c0b3a1"},
+ {file = "grpcio-1.59.2-cp38-cp38-manylinux_2_17_aarch64.whl", hash =
"sha256:e1727c1c0e394096bb9af185c6923e8ea55a5095b8af44f06903bcc0e06800a2"},
+ {file =
"grpcio-1.59.2-cp38-cp38-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:5d573e70a6fe77555fb6143c12d3a7d3fa306632a3034b4e7c59ca09721546f8"},
+ {file =
"grpcio-1.59.2-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash
= "sha256:31176aa88f36020055ace9adff2405a33c8bdbfa72a9c4980e25d91b2f196873"},
+ {file = "grpcio-1.59.2-cp38-cp38-musllinux_1_1_i686.whl", hash =
"sha256:11168ef43e4a43ff1b1a65859f3e0ef1a173e277349e7fb16923ff108160a8cd"},
+ {file = "grpcio-1.59.2-cp38-cp38-musllinux_1_1_x86_64.whl", hash =
"sha256:53c9aa5ddd6857c0a1cd0287225a2a25873a8e09727c2e95c4aebb1be83a766a"},
+ {file = "grpcio-1.59.2-cp38-cp38-win32.whl", hash =
"sha256:3b4368b33908f683a363f376dfb747d40af3463a6e5044afee07cf9436addf96"},
+ {file = "grpcio-1.59.2-cp38-cp38-win_amd64.whl", hash =
"sha256:0a754aff9e3af63bdc4c75c234b86b9d14e14a28a30c4e324aed1a9b873d755f"},
+ {file = "grpcio-1.59.2-cp39-cp39-linux_armv7l.whl", hash =
"sha256:1f9524d1d701e399462d2c90ba7c193e49d1711cf429c0d3d97c966856e03d00"},
+ {file = "grpcio-1.59.2-cp39-cp39-macosx_10_10_universal2.whl", hash =
"sha256:f93dbf58f03146164048be5426ffde298b237a5e059144847e4940f5b80172c3"},
+ {file = "grpcio-1.59.2-cp39-cp39-manylinux_2_17_aarch64.whl", hash =
"sha256:6da6dea3a1bacf99b3c2187e296db9a83029ed9c38fd4c52b7c9b7326d13c828"},
+ {file =
"grpcio-1.59.2-cp39-cp39-manylinux_2_17_i686.manylinux2014_i686.whl", hash =
"sha256:c5f09cffa619adfb44799fa4a81c2a1ad77c887187613fb0a8f201ab38d89ba1"},
+ {file =
"grpcio-1.59.2-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash
= "sha256:c35aa9657f5d5116d23b934568e0956bd50c615127810fffe3ac356a914c176a"},
+ {file = "grpcio-1.59.2-cp39-cp39-musllinux_1_1_i686.whl", hash =
"sha256:74100fecaec8a535e380cf5f2fb556ff84957d481c13e54051c52e5baac70541"},
+ {file = "grpcio-1.59.2-cp39-cp39-musllinux_1_1_x86_64.whl", hash =
"sha256:128e20f57c5f27cb0157e73756d1586b83c1b513ebecc83ea0ac37e4b0e4e758"},
+ {file = "grpcio-1.59.2-cp39-cp39-win32.whl", hash =
"sha256:686e975a5d16602dc0982c7c703948d17184bd1397e16c8ee03511ecb8c4cdda"},
+ {file = "grpcio-1.59.2-cp39-cp39-win_amd64.whl", hash =
"sha256:242adc47725b9a499ee77c6a2e36688fa6c96484611f33b1be4c57ab075a92dd"},
+ {file = "grpcio-1.59.2.tar.gz", hash =
"sha256:d8f9cd4ad1be90b0cf350a2f04a38a36e44a026cac1e036ac593dc48efe91d52"},
+]
+
+[package.extras]
+protobuf = ["grpcio-tools (>=1.59.2)"]
+
+[[package]]
+name = "grpcio-tools"
+version = "1.59.2"
+description = "Protobuf code generator for gRPC"
+optional = false
+python-versions = ">=3.7"
+files = [
+ {file = "grpcio-tools-1.59.2.tar.gz", hash =
"sha256:75905266cf90f1866b322575c2edcd4b36532c33fc512bb1b380dc58d84b1030"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-linux_armv7l.whl", hash =
"sha256:9b2885c0e2c9a97bde33497a919032afbd8b5c6dc2f8d4dd4198e77226e0de05"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-macosx_12_0_universal2.whl", hash
= "sha256:2f410375830a9bb7140a07da4d75bf380e0958377bed50d77d1dae302de4314e"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-manylinux_2_17_aarch64.whl", hash
= "sha256:e21fc172522d2dda815223a359b2aca9bc317a1b5e5dea5a58cd5079333af133"},
+ {file =
"grpcio_tools-1.59.2-cp310-cp310-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:072a7ce979ea4f7579c3c99fcbde3d1882c3d1942a3b51d159f67af83b714cd8"},
+ {file =
"grpcio_tools-1.59.2-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:b38f8edb2909702c2478b52f6213982c21e4f66f739ac953b91f97863ba2c06a"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-musllinux_1_1_i686.whl", hash =
"sha256:12fdee2de80d83eadb1294e0f8a0cb6cefcd2e4988ed680038ab09cd04361ee4"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-musllinux_1_1_x86_64.whl", hash =
"sha256:a3cb707da722a0b6c4021fc2cc1c005a8d4037d8ad0252f93df318b9b8a6b4f3"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-win32.whl", hash =
"sha256:ec2fbb02ebb9f2ae1b1c69cccf913dee8c41f5acad94014d3ce11b53720376e3"},
+ {file = "grpcio_tools-1.59.2-cp310-cp310-win_amd64.whl", hash =
"sha256:b0dc271a200dbab6547b2c73fcbdb7efe94c31cb633aa20d073f7cf4493493e1"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-linux_armv7l.whl", hash =
"sha256:d634b65cc8ee769edccf1647d8a16861a27e0d8cbd787c711168d2c5e9bddbd1"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-macosx_10_10_universal2.whl",
hash =
"sha256:b0b712acec00a9cbc2204c271d638062a2cb8ce74f25d158b023ff6e93182659"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-manylinux_2_17_aarch64.whl", hash
= "sha256:dd5c78f8e7c6e721b9009c92481a0e3b30a9926ef721120723a03b8a34a34fb9"},
+ {file =
"grpcio_tools-1.59.2-cp311-cp311-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:724f4f0eecc17fa66216eebfff145631070f04ed7fb4ddf7a7d1c4f954ecc2a1"},
+ {file =
"grpcio_tools-1.59.2-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:77ec33ddee691e60511e2a7c793aad4cf172ae20e08d95c786cbba395f6203a7"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-musllinux_1_1_i686.whl", hash =
"sha256:fa1b9dee7811fad081816e884d063c4dd4946dba61aa54243b4c76c311090c48"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-musllinux_1_1_x86_64.whl", hash =
"sha256:ba8dba19e7b2b6f7369004533866f222ba483b9e14d2d152ecf9339c0df1283a"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-win32.whl", hash =
"sha256:df35d145bc2f6e5f57b74cb69f66526675a5f2dcf7d54617ce0deff0c82cca0a"},
+ {file = "grpcio_tools-1.59.2-cp311-cp311-win_amd64.whl", hash =
"sha256:99ddc0f5304071a355c261ae49ea5d29b9e9b6dcf422dfc55ada70a243e27e8f"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-linux_armv7l.whl", hash =
"sha256:670f5889853215999eb3511a623dd7dff01b1ce1a64610d13366e0fd337f8c79"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-macosx_10_10_universal2.whl",
hash =
"sha256:1e949e66d4555ce319fd7acef90df625138078d8729c4dc6f6a9f05925034433"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-manylinux_2_17_aarch64.whl", hash
= "sha256:09d809ca88999b2578119683f9f0f6a9b42de95ea21550852114a1540b6a642c"},
+ {file =
"grpcio_tools-1.59.2-cp312-cp312-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:db0925545180223fabd6da9b34513efac83aa16673ef8b1cb0cc678e8cf0923c"},
+ {file =
"grpcio_tools-1.59.2-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:a2ccb59dfbf2ebd668a5a7c4b7bb2b859859641d2b199114b557cd045aac6102"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-musllinux_1_1_i686.whl", hash =
"sha256:12cc7698fad48866f68fdef831685cb31ef5814ac605d248c4e5fc964a6fb3f6"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-musllinux_1_1_x86_64.whl", hash =
"sha256:55c401599d5093c4cfa83b8f0ee9757b4d6d3029b10bd67be2cffeada7a44961"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-win32.whl", hash =
"sha256:896f5cdf58f658025a4f7e4ea96c81183b4b6a4b1b4d92ae66d112ac91f062f1"},
+ {file = "grpcio_tools-1.59.2-cp312-cp312-win_amd64.whl", hash =
"sha256:b53db1523015a3acda75722357df6c94afae37f6023800c608e09a5c05393804"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-linux_armv7l.whl", hash =
"sha256:d08b398509ea4d544bcecddd9a21f59dc556396916c3915904cac206af2db72b"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-macosx_10_10_universal2.whl", hash
= "sha256:09749e832e06493841000275248b031f7154665900d1e1b0e42fc17a64bf904d"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-manylinux_2_17_aarch64.whl", hash
= "sha256:e972746000aa192521715f776fab617a3437bed29e90fe0e0fd0d0d6f498d7d4"},
+ {file =
"grpcio_tools-1.59.2-cp37-cp37m-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:cbeeb3d8ec4cb25c92e17bfbdcef3c3669e85c5ee787a6e581cb942bc0ae2b88"},
+ {file =
"grpcio_tools-1.59.2-cp37-cp37m-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:ed8e6632d8d839456332d97b96db10bd2dbf3078e728d063394ac2d54597ad80"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-musllinux_1_1_i686.whl", hash =
"sha256:531f87c8e884c6a2e58f040039dfbfe997a4e33baa58f7c7d9993db37b1f5ad0"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-musllinux_1_1_x86_64.whl", hash =
"sha256:feca316e17cfead823af6eae0fc20c0d5299a94d71cfb7531a0e92d050a5fb2f"},
+ {file = "grpcio_tools-1.59.2-cp37-cp37m-win_amd64.whl", hash =
"sha256:41b5dd6a06c2563ac3b3adda6d875b15e63eb7b1629e85fc9af608c3a76c4c82"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-linux_armv7l.whl", hash =
"sha256:7ec536cdae870a74080c665cfb1dca8d0784a931aa3c26376ef971a3a51b59d4"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-macosx_10_10_universal2.whl", hash
= "sha256:9c106ebbed0db446f59f0efe5c3fce33a0a21bf75b392966585e4b5934891b92"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-manylinux_2_17_aarch64.whl", hash =
"sha256:32141ef309543a446337e934f0b7a2565a6fca890ff4e543630a09ef72c8d00b"},
+ {file =
"grpcio_tools-1.59.2-cp38-cp38-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:5f2ce5ecd63c492949b03af73b1dd6d502c567cc2f9c2057137e518b0c702a01"},
+ {file =
"grpcio_tools-1.59.2-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:2a9ce2a209871ed1c5ae2229e6f4f5a3ea96d83b7871df5d9773d72a72545683"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-musllinux_1_1_i686.whl", hash =
"sha256:7f0e26af7c07bfa906c91ca9f5932514928a7f032f5f20aecad6b5541037de7e"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-musllinux_1_1_x86_64.whl", hash =
"sha256:48782727c5cff8b8c96e028a8a58614ff6a37eadc0db85866516210c7aafe9ae"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-win32.whl", hash =
"sha256:4a1810bc5de51cc162a19ed3c11da8ddc64d8cfcba049ef337c20fcb397f048b"},
+ {file = "grpcio_tools-1.59.2-cp38-cp38-win_amd64.whl", hash =
"sha256:3cf9949a2aadcece3c1e0dd59249aea53dbfc8cc94f7d707797acd67cf6cf931"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-linux_armv7l.whl", hash =
"sha256:f52e0ce8f2dcf1f160c847304016c446075a83ab925d98933d4681bfa8af2962"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-macosx_10_10_universal2.whl", hash
= "sha256:eb597d6bf9f5bfa54d00546e828f0d4e2c69250d1bc17c27903c0c7b66372135"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-manylinux_2_17_aarch64.whl", hash =
"sha256:17ef468836d7cf0b2419f4d5c7ac84ec2d598a1ae410773585313edacf7c393e"},
+ {file =
"grpcio_tools-1.59.2-cp39-cp39-manylinux_2_17_i686.manylinux2014_i686.whl",
hash =
"sha256:dee5f7e7a56177234e61a483c70ca2ae34e73128372c801bb7039993870889f1"},
+ {file =
"grpcio_tools-1.59.2-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
hash =
"sha256:f50ff312b88918c5a6461e45c5e03869749a066b1c24a7327e8e13e117efe4fc"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-musllinux_1_1_i686.whl", hash =
"sha256:a85da4200295ee17e3c1ae068189a43844420ed7e9d531a042440f52de486dfb"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-musllinux_1_1_x86_64.whl", hash =
"sha256:f518f22a3082de00f0d7a216e96366a87e6973111085ba1603c3bfa7dba2e728"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-win32.whl", hash =
"sha256:6e735a26e8ea8bb89dc69343d1d00ea607449c6d81e21f339ee118562f3d1931"},
+ {file = "grpcio_tools-1.59.2-cp39-cp39-win_amd64.whl", hash =
"sha256:3491cb69c909d586c23d7e6d0ac87844ca22f496f505ce429c0d3301234f2cf3"},
+]
+
+[package.dependencies]
+grpcio = ">=1.59.2"
+protobuf = ">=4.21.6,<5.0dev"
+setuptools = "*"
+
+[[package]]
+name = "protobuf"
+version = "4.25.0"
+description = ""
+optional = false
+python-versions = ">=3.8"
+files = [
+ {file = "protobuf-4.25.0-cp310-abi3-win32.whl", hash =
"sha256:5c1203ac9f50e4853b0a0bfffd32c67118ef552a33942982eeab543f5c634395"},
+ {file = "protobuf-4.25.0-cp310-abi3-win_amd64.whl", hash =
"sha256:c40ff8f00aa737938c5378d461637d15c442a12275a81019cc2fef06d81c9419"},
+ {file = "protobuf-4.25.0-cp37-abi3-macosx_10_9_universal2.whl", hash =
"sha256:cf21faba64cd2c9a3ed92b7a67f226296b10159dbb8fbc5e854fc90657d908e4"},
+ {file = "protobuf-4.25.0-cp37-abi3-manylinux2014_aarch64.whl", hash =
"sha256:32ac2100b0e23412413d948c03060184d34a7c50b3e5d7524ee96ac2b10acf51"},
+ {file = "protobuf-4.25.0-cp37-abi3-manylinux2014_x86_64.whl", hash =
"sha256:683dc44c61f2620b32ce4927de2108f3ebe8ccf2fd716e1e684e5a50da154054"},
+ {file = "protobuf-4.25.0-cp38-cp38-win32.whl", hash =
"sha256:1a3ba712877e6d37013cdc3476040ea1e313a6c2e1580836a94f76b3c176d575"},
+ {file = "protobuf-4.25.0-cp38-cp38-win_amd64.whl", hash =
"sha256:b2cf8b5d381f9378afe84618288b239e75665fe58d0f3fd5db400959274296e9"},
+ {file = "protobuf-4.25.0-cp39-cp39-win32.whl", hash =
"sha256:63714e79b761a37048c9701a37438aa29945cd2417a97076048232c1df07b701"},
+ {file = "protobuf-4.25.0-cp39-cp39-win_amd64.whl", hash =
"sha256:d94a33db8b7ddbd0af7c467475fb9fde0c705fb315a8433c0e2020942b863a1f"},
+ {file = "protobuf-4.25.0-py3-none-any.whl", hash =
"sha256:1a53d6f64b00eecf53b65ff4a8c23dc95df1fa1e97bb06b8122e5a64f49fc90a"},
+ {file = "protobuf-4.25.0.tar.gz", hash =
"sha256:68f7caf0d4f012fd194a301420cf6aa258366144d814f358c5b32558228afa7c"},
+]
+
+[[package]]
+name = "setuptools"
+version = "68.2.2"
+description = "Easily download, build, install, upgrade, and uninstall Python
packages"
+optional = false
+python-versions = ">=3.8"
+files = [
+ {file = "setuptools-68.2.2-py3-none-any.whl", hash =
"sha256:b454a35605876da60632df1a60f736524eb73cc47bbc9f3f1ef1b644de74fd2a"},
+ {file = "setuptools-68.2.2.tar.gz", hash =
"sha256:4ac1475276d2f1c48684874089fefcd83bd7162ddaafb81fac866ba0db282a87"},
+]
+
+[package.extras]
+docs = ["furo", "jaraco.packaging (>=9.3)", "jaraco.tidelift (>=1.4)",
"pygments-github-lexers (==0.0.5)", "rst.linker (>=1.9)", "sphinx (>=3.5)",
"sphinx-favicon", "sphinx-hoverxref (<2)", "sphinx-inline-tabs", "sphinx-lint",
"sphinx-notfound-page (>=1,<2)", "sphinx-reredirects",
"sphinxcontrib-towncrier"]
+testing = ["build[virtualenv]", "filelock (>=3.4.0)", "flake8-2020",
"ini2toml[lite] (>=0.9)", "jaraco.develop (>=7.21)", "jaraco.envs (>=2.2)",
"jaraco.path (>=3.2.0)", "pip (>=19.1)", "pytest (>=6)", "pytest-black
(>=0.3.7)", "pytest-checkdocs (>=2.4)", "pytest-cov", "pytest-enabler (>=2.2)",
"pytest-mypy (>=0.9.1)", "pytest-perf", "pytest-ruff", "pytest-timeout",
"pytest-xdist", "tomli-w (>=1.0.0)", "virtualenv (>=13.0.0)", "wheel"]
+testing-integration = ["build[virtualenv] (>=1.0.3)", "filelock (>=3.4.0)",
"jaraco.envs (>=2.2)", "jaraco.path (>=3.2.0)", "packaging (>=23.1)", "pytest",
"pytest-enabler", "pytest-xdist", "tomli", "virtualenv (>=13.0.0)", "wheel"]
+
+[[package]]
+name = "soupsieve"
+version = "2.5"
+description = "A modern CSS selector implementation for Beautiful Soup."
+optional = false
+python-versions = ">=3.8"
+files = [
+ {file = "soupsieve-2.5-py3-none-any.whl", hash =
"sha256:eaa337ff55a1579b6549dc679565eac1e3d000563bcb1c8ab0d0fefbc0c2cdc7"},
+ {file = "soupsieve-2.5.tar.gz", hash =
"sha256:5663d5a7b3bfaeee0bc4372e7fc48f9cff4940b3eec54a6451cc5299f1097690"},
+]
+
+[metadata]
+lock-version = "2.0"
+python-versions = "^3.8"
+content-hash =
"1f2dadd2821a62cdfb7562f211be17c8bd12b762551bdb923954f9e7404087ec"
diff --git a/.test-infra/mock-apis/pyproject.toml
b/.test-infra/mock-apis/pyproject.toml
new file mode 100644
index 00000000000..ed3f035cbf4
--- /dev/null
+++ b/.test-infra/mock-apis/pyproject.toml
@@ -0,0 +1,38 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+[tool.poetry]
+name = "mock-apis"
+version = "0.1.0"
+authors = ["Ritesh Ghorse <riteshgho...@gmail.com>, Damon Douglas <>"]
+license = "Apache-2.0"
+description = ""
+readme = "README.md"
+packages = [
+ { include = "src/main/python/"}
+]
+
+[tool.poetry.dependencies]
+python = "^3.8"
+google = "^3.0.0"
+grpcio = "^1.59.2"
+grpcio-tools = "^1.59.2"
+
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"
diff --git a/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2.py
b/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2.py
new file mode 100644
index 00000000000..0a1bd2aff77
--- /dev/null
+++ b/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2.py
@@ -0,0 +1,47 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler. DO NOT EDIT!
+# source: proto/echo/v1/echo.proto
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR =
_descriptor_pool.Default().AddSerializedFile(b'\n\x18proto/echo/v1/echo.proto\x12\rproto.echo.v1\"7\n\x0b\x45\x63hoRequest\x12\x0e\n\x02id\x18\x01
\x01(\tR\x02id\x12\x18\n\x07payload\x18\x02
\x01(\x0cR\x07payload\"8\n\x0c\x45\x63hoResponse\x12\x0e\n\x02id\x18\x01
\x01(\tR\x02id\x12\x18\n\x07payload\x18\x02
\x01(\x0cR\x07payload2P\n\x0b\x45\x63hoService\x12\x41\n\x04\x45\x63ho\x12\x1a.proto.echo.v1.EchoRequest\x1a\x1b.proto.echo.v1.EchoResponse\"\x00\x42;\n*org.apache.beam.te
[...]
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'proto.echo.v1.echo_pb2',
_globals)
+if _descriptor._USE_C_DESCRIPTORS == False:
+ _globals['DESCRIPTOR']._options = None
+ _globals['DESCRIPTOR']._serialized_options =
b'\n*org.apache.beam.testinfra.mockapis.echo.v1Z\rproto/echo/v1'
+ _globals['_ECHOREQUEST']._serialized_start=43
+ _globals['_ECHOREQUEST']._serialized_end=98
+ _globals['_ECHORESPONSE']._serialized_start=100
+ _globals['_ECHORESPONSE']._serialized_end=156
+ _globals['_ECHOSERVICE']._serialized_start=158
+ _globals['_ECHOSERVICE']._serialized_end=238
+# @@protoc_insertion_point(module_scope)
diff --git
a/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2_grpc.py
b/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2_grpc.py
new file mode 100644
index 00000000000..0a92ee4af6c
--- /dev/null
+++ b/.test-infra/mock-apis/src/main/python/proto/echo/v1/echo_pb2_grpc.py
@@ -0,0 +1,87 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from proto.echo.v1 import echo_pb2 as proto_dot_echo_dot_v1_dot_echo__pb2
+
+
+class EchoServiceStub(object):
+ """EchoService simulates a mock API that echos a request.
+ """
+
+ def __init__(self, channel):
+ """Constructor.
+
+ Args:
+ channel: A grpc.Channel.
+ """
+ self.Echo = channel.unary_unary(
+ '/proto.echo.v1.EchoService/Echo',
+
request_serializer=proto_dot_echo_dot_v1_dot_echo__pb2.EchoRequest.SerializeToString,
+
response_deserializer=proto_dot_echo_dot_v1_dot_echo__pb2.EchoResponse.FromString,
+ )
+
+
+class EchoServiceServicer(object):
+ """EchoService simulates a mock API that echos a request.
+ """
+
+ def Echo(self, request, context):
+ """Echo an EchoRequest payload in an EchoResponse.
+ """
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
+
+def add_EchoServiceServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'Echo': grpc.unary_unary_rpc_method_handler(
+ servicer.Echo,
+
request_deserializer=proto_dot_echo_dot_v1_dot_echo__pb2.EchoRequest.FromString,
+
response_serializer=proto_dot_echo_dot_v1_dot_echo__pb2.EchoResponse.SerializeToString,
+ ),
+ }
+ generic_handler = grpc.method_handlers_generic_handler(
+ 'proto.echo.v1.EchoService', rpc_method_handlers)
+ server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class EchoService(object):
+ """EchoService simulates a mock API that echos a request.
+ """
+
+ @staticmethod
+ def Echo(request,
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
+ return grpc.experimental.unary_unary(request, target,
'/proto.echo.v1.EchoService/Echo',
+ proto_dot_echo_dot_v1_dot_echo__pb2.EchoRequest.SerializeToString,
+ proto_dot_echo_dot_v1_dot_echo__pb2.EchoResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout,
metadata)
