Skip to content

Commit a4e0639

Browse files
yoshi-automationyoshi-automation
authored
fix: remove client recv msg limit fix: add enums to types/__init__.py (#56)
This PR was generated using Autosynth. 🌈 Synth log will be available here: https://source.cloud.google.com/results/invocations/71c982aa-fc95-4efe-80a5-77a98b67742a/targets - [ ] To automatically regenerate this PR, check this box. PiperOrigin-RevId: 347055288 Source-Link: googleapis/googleapis@dd372aa
1 parent 14c5a77 commit a4e0639

File tree

16 files changed

+83
-11
lines changed

16 files changed

+83
-11
lines changed

‎packages/google-cloud-tasks/google/cloud/tasks_v2/services/cloud_tasks/transports/__init__.py‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = CloudTasksGrpcTransport
2929
_transport_registry["grpc_asyncio"] = CloudTasksGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"CloudTasksTransport",
3433
"CloudTasksGrpcTransport",

‎packages/google-cloud-tasks/google/cloud/tasks_v2/services/cloud_tasks/transports/grpc.py‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,10 @@ def __init__(
154154
ssl_credentials=ssl_credentials,
155155
scopes=scopes or self.AUTH_SCOPES,
156156
quota_project_id=quota_project_id,
157+
options=[
158+
("grpc.max_send_message_length", -1),
159+
("grpc.max_receive_message_length", -1),
160+
],
157161
)
158162
self._ssl_channel_credentials = ssl_credentials
159163
else:
@@ -172,6 +176,10 @@ def __init__(
172176
ssl_credentials=ssl_channel_credentials,
173177
scopes=scopes or self.AUTH_SCOPES,
174178
quota_project_id=quota_project_id,
179+
options=[
180+
("grpc.max_send_message_length", -1),
181+
("grpc.max_receive_message_length", -1),
182+
],
175183
)
176184

177185
self._stubs = {} # type: Dict[str, Callable]
@@ -198,7 +206,7 @@ def create_channel(
198206
) -> grpc.Channel:
199207
"""Create and return a gRPC channel object.
200208
Args:
201-
address (Optionsl[str]): The host for the channel to use.
209+
address (Optional[str]): The host for the channel to use.
202210
credentials (Optional[~.Credentials]): The
203211
authorization credentials to attach to requests. These
204212
credentials identify this application to the service. If

‎packages/google-cloud-tasks/google/cloud/tasks_v2/services/cloud_tasks/transports/grpc_asyncio.py‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,10 @@ def __init__(
199199
ssl_credentials=ssl_credentials,
200200
scopes=scopes or self.AUTH_SCOPES,
201201
quota_project_id=quota_project_id,
202+
options=[
203+
("grpc.max_send_message_length", -1),
204+
("grpc.max_receive_message_length", -1),
205+
],
202206
)
203207
self._ssl_channel_credentials = ssl_credentials
204208
else:
@@ -217,6 +221,10 @@ def __init__(
217221
ssl_credentials=ssl_channel_credentials,
218222
scopes=scopes or self.AUTH_SCOPES,
219223
quota_project_id=quota_project_id,
224+
options=[
225+
("grpc.max_send_message_length", -1),
226+
("grpc.max_receive_message_length", -1),
227+
],
220228
)
221229

222230
# Run the base constructor.

‎packages/google-cloud-tasks/google/cloud/tasks_v2/types/__init__.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
AppEngineRouting,
2222
OAuthToken,
2323
OidcToken,
24+
HttpMethod,
2425
)
2526
from .queue import (
2627
Queue,
@@ -50,13 +51,13 @@
5051
RunTaskRequest,
5152
)
5253

53-
5454
__all__ = (
5555
"HttpRequest",
5656
"AppEngineHttpRequest",
5757
"AppEngineRouting",
5858
"OAuthToken",
5959
"OidcToken",
60+
"HttpMethod",
6061
"Queue",
6162
"RateLimits",
6263
"RetryConfig",

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/transports/__init__.py‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = CloudTasksGrpcTransport
2929
_transport_registry["grpc_asyncio"] = CloudTasksGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"CloudTasksTransport",
3433
"CloudTasksGrpcTransport",

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/transports/grpc.py‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,10 @@ def __init__(
154154
ssl_credentials=ssl_credentials,
155155
scopes=scopes or self.AUTH_SCOPES,
156156
quota_project_id=quota_project_id,
157+
options=[
158+
("grpc.max_send_message_length", -1),
159+
("grpc.max_receive_message_length", -1),
160+
],
157161
)
158162
self._ssl_channel_credentials = ssl_credentials
159163
else:
@@ -172,6 +176,10 @@ def __init__(
172176
ssl_credentials=ssl_channel_credentials,
173177
scopes=scopes or self.AUTH_SCOPES,
174178
quota_project_id=quota_project_id,
179+
options=[
180+
("grpc.max_send_message_length", -1),
181+
("grpc.max_receive_message_length", -1),
182+
],
175183
)
176184

177185
self._stubs = {} # type: Dict[str, Callable]
@@ -198,7 +206,7 @@ def create_channel(
198206
) -> grpc.Channel:
199207
"""Create and return a gRPC channel object.
200208
Args:
201-
address (Optionsl[str]): The host for the channel to use.
209+
address (Optional[str]): The host for the channel to use.
202210
credentials (Optional[~.Credentials]): The
203211
authorization credentials to attach to requests. These
204212
credentials identify this application to the service. If

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/transports/grpc_asyncio.py‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,10 @@ def __init__(
199199
ssl_credentials=ssl_credentials,
200200
scopes=scopes or self.AUTH_SCOPES,
201201
quota_project_id=quota_project_id,
202+
options=[
203+
("grpc.max_send_message_length", -1),
204+
("grpc.max_receive_message_length", -1),
205+
],
202206
)
203207
self._ssl_channel_credentials = ssl_credentials
204208
else:
@@ -217,6 +221,10 @@ def __init__(
217221
ssl_credentials=ssl_channel_credentials,
218222
scopes=scopes or self.AUTH_SCOPES,
219223
quota_project_id=quota_project_id,
224+
options=[
225+
("grpc.max_send_message_length", -1),
226+
("grpc.max_receive_message_length", -1),
227+
],
220228
)
221229

222230
# Run the base constructor.

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/types/__init__.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
AppEngineHttpTarget,
2222
AppEngineHttpRequest,
2323
AppEngineRouting,
24+
HttpMethod,
2425
)
2526
from .queue import (
2627
Queue,
@@ -55,13 +56,13 @@
5556
RunTaskRequest,
5657
)
5758

58-
5959
__all__ = (
6060
"PullTarget",
6161
"PullMessage",
6262
"AppEngineHttpTarget",
6363
"AppEngineHttpRequest",
6464
"AppEngineRouting",
65+
"HttpMethod",
6566
"Queue",
6667
"RateLimits",
6768
"RetryConfig",

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta3/services/cloud_tasks/transports/__init__.py‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = CloudTasksGrpcTransport
2929
_transport_registry["grpc_asyncio"] = CloudTasksGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"CloudTasksTransport",
3433
"CloudTasksGrpcTransport",

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta3/services/cloud_tasks/transports/grpc.py‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,10 @@ def __init__(
154154
ssl_credentials=ssl_credentials,
155155
scopes=scopes or self.AUTH_SCOPES,
156156
quota_project_id=quota_project_id,
157+
options=[
158+
("grpc.max_send_message_length", -1),
159+
("grpc.max_receive_message_length", -1),
160+
],
157161
)
158162
self._ssl_channel_credentials = ssl_credentials
159163
else:
@@ -172,6 +176,10 @@ def __init__(
172176
ssl_credentials=ssl_channel_credentials,
173177
scopes=scopes or self.AUTH_SCOPES,
174178
quota_project_id=quota_project_id,
179+
options=[
180+
("grpc.max_send_message_length", -1),
181+
("grpc.max_receive_message_length", -1),
182+
],
175183
)
176184

177185
self._stubs = {} # type: Dict[str, Callable]
@@ -198,7 +206,7 @@ def create_channel(
198206
) -> grpc.Channel:
199207
"""Create and return a gRPC channel object.
200208
Args:
201-
address (Optionsl[str]): The host for the channel to use.
209+
address (Optional[str]): The host for the channel to use.
202210
credentials (Optional[~.Credentials]): The
203211
authorization credentials to attach to requests. These
204212
credentials identify this application to the service. If

0 commit comments

Comments
 (0)