Skip to content

Commit 46c3e97

Browse files
chore: [Many APIs] Update gapic-generator-python to v1.19.1 (googleapis#13156)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 684571179 Source-Link: googleapis/googleapis@fbdc238 Source-Link: https://github.com/googleapis/googleapis-gen/commit/3a2cdcfb80c2d0f5ec0cc663c2bab0a9486229d0 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLW9zLWxvZ2luLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBhcmFsbGVsc3RvcmUvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBoaXNoaW5nLXByb3RlY3Rpb24vLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBvbGljeS10cm91Ymxlc2hvb3Rlci8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBvbGljeXNpbXVsYXRvci8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBvbGljeXRyb3VibGVzaG9vdGVyLWlhbS8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXByaXZhdGUtY2EvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXByaXZhdGUtY2F0YWxvZy8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXByaXZpbGVnZWRhY2Nlc3NtYW5hZ2VyLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXB1YmxpYy1jYS8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJhcGlkbWlncmF0aW9uYXNzZXNzbWVudC8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlY2FwdGNoYS1lbnRlcnByaXNlLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlY29tbWVuZGF0aW9ucy1haS8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlY29tbWVuZGVyLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlZGlzLWNsdXN0ZXIvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlZGlzLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlc291cmNlLW1hbmFnZXIvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ== Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJlc291cmNlLXNldHRpbmdzLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0= Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJldGFpbC8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXJ1bi8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Anthonios Partheniou <partheniou@google.com>
1 parent 6e83b29 commit 46c3e97

File tree

600 files changed

+210793
-154381
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

600 files changed

+210793
-154381
lines changed
Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
2+
transport inheritance structure
3+
_______________________________
4+
5+
`OsLoginServiceTransport` is the ABC for all transports.
6+
- public child `OsLoginServiceGrpcTransport` for sync gRPC transport (defined in `grpc.py`).
7+
- public child `OsLoginServiceGrpcAsyncIOTransport` for async gRPC transport (defined in `grpc_asyncio.py`).
8+
- private child `_BaseOsLoginServiceRestTransport` for base REST transport with inner classes `_BaseMETHOD` (defined in `rest_base.py`).
9+
- public child `OsLoginServiceRestTransport` for sync REST transport with inner classes `METHOD` derived from the parent's corresponding `_BaseMETHOD` classes (defined in `rest.py`).

packages/google-cloud-os-login/google/cloud/oslogin_v1/services/os_login_service/transports/grpc_asyncio.py

Lines changed: 20 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16+
import inspect
1617
from typing import Awaitable, Callable, Dict, Optional, Sequence, Tuple, Union
1718
import warnings
1819

@@ -232,6 +233,9 @@ def __init__(
232233
)
233234

234235
# Wrap messages. This must be done after self._grpc_channel exists
236+
self._wrap_with_kind = (
237+
"kind" in inspect.signature(gapic_v1.method_async.wrap_method).parameters
238+
)
235239
self._prep_wrapped_messages(client_info)
236240

237241
@property
@@ -437,12 +441,12 @@ def update_ssh_public_key(
437441
def _prep_wrapped_messages(self, client_info):
438442
"""Precompute the wrapped methods, overriding the base class method to use async wrappers."""
439443
self._wrapped_methods = {
440-
self.create_ssh_public_key: gapic_v1.method_async.wrap_method(
444+
self.create_ssh_public_key: self._wrap_method(
441445
self.create_ssh_public_key,
442446
default_timeout=None,
443447
client_info=client_info,
444448
),
445-
self.delete_posix_account: gapic_v1.method_async.wrap_method(
449+
self.delete_posix_account: self._wrap_method(
446450
self.delete_posix_account,
447451
default_retry=retries.AsyncRetry(
448452
initial=0.1,
@@ -457,7 +461,7 @@ def _prep_wrapped_messages(self, client_info):
457461
default_timeout=10.0,
458462
client_info=client_info,
459463
),
460-
self.delete_ssh_public_key: gapic_v1.method_async.wrap_method(
464+
self.delete_ssh_public_key: self._wrap_method(
461465
self.delete_ssh_public_key,
462466
default_retry=retries.AsyncRetry(
463467
initial=0.1,
@@ -472,7 +476,7 @@ def _prep_wrapped_messages(self, client_info):
472476
default_timeout=10.0,
473477
client_info=client_info,
474478
),
475-
self.get_login_profile: gapic_v1.method_async.wrap_method(
479+
self.get_login_profile: self._wrap_method(
476480
self.get_login_profile,
477481
default_retry=retries.AsyncRetry(
478482
initial=0.1,
@@ -487,7 +491,7 @@ def _prep_wrapped_messages(self, client_info):
487491
default_timeout=10.0,
488492
client_info=client_info,
489493
),
490-
self.get_ssh_public_key: gapic_v1.method_async.wrap_method(
494+
self.get_ssh_public_key: self._wrap_method(
491495
self.get_ssh_public_key,
492496
default_retry=retries.AsyncRetry(
493497
initial=0.1,
@@ -502,7 +506,7 @@ def _prep_wrapped_messages(self, client_info):
502506
default_timeout=10.0,
503507
client_info=client_info,
504508
),
505-
self.import_ssh_public_key: gapic_v1.method_async.wrap_method(
509+
self.import_ssh_public_key: self._wrap_method(
506510
self.import_ssh_public_key,
507511
default_retry=retries.AsyncRetry(
508512
initial=0.1,
@@ -517,7 +521,7 @@ def _prep_wrapped_messages(self, client_info):
517521
default_timeout=10.0,
518522
client_info=client_info,
519523
),
520-
self.update_ssh_public_key: gapic_v1.method_async.wrap_method(
524+
self.update_ssh_public_key: self._wrap_method(
521525
self.update_ssh_public_key,
522526
default_retry=retries.AsyncRetry(
523527
initial=0.1,
@@ -534,8 +538,17 @@ def _prep_wrapped_messages(self, client_info):
534538
),
535539
}
536540

541+
def _wrap_method(self, func, *args, **kwargs):
542+
if self._wrap_with_kind: # pragma: NO COVER
543+
kwargs["kind"] = self.kind
544+
return gapic_v1.method_async.wrap_method(func, *args, **kwargs)
545+
537546
def close(self):
538547
return self.grpc_channel.close()
539548

549+
@property
550+
def kind(self) -> str:
551+
return "grpc_asyncio"
552+
540553

541554
__all__ = ("OsLoginServiceGrpcAsyncIOTransport",)

0 commit comments

Comments
 (0)