update goldens

Author: ohmayr

WORKSPACE

@@ -123,3 +123,13 @@ switched_rules_by_language(
     gapic = True,
     grpc = True,
 )
+
+
+# BEGIN workaround
+load("@rules_python//python:repositories.bzl", "python_register_toolchains")
+
+python_register_toolchains(
+    name = "python311",
+    python_version = "3.11",
+)
+# END workaround

tests/integration/goldens/asset/google/cloud/asset_v1/__init__.py

@@ -20,9 +20,9 @@
 
 __version__ = package_version.__version__
 
-if sys.version_info >= (3, 8):  # pragma: NO COVER
+if sys.version_info >= (3, 8):  # pragma: NO COVER # fmt: skip
     from importlib import metadata
-else:  # pragma: NO COVER
+else:  # pragma: NO COVER # fmt: skip
     # TODO(https://github.com/googleapis/python-api-core/issues/835): Remove
     # this code path once we drop support for Python 3.7
     import importlib_metadata as metadata
@@ -109,10 +109,10 @@
 from .types.assets import TimeWindow
 from .types.assets import VersionedResource
 
-if hasattr(api_core, "check_python_version") and hasattr(api_core, "check_dependency_versions"):   # pragma: NO COVER
+if hasattr(api_core, "check_python_version") and hasattr(api_core, "check_dependency_versions"):   # pragma: NO COVER # fmt: skip
     api_core.check_python_version("google.cloud.asset_v1") # type: ignore
     api_core.check_dependency_versions("google.cloud.asset_v1") # type: ignore
-else:   # pragma: NO COVER
+else:   # pragma: NO COVER # fmt: skip
     # An older version of api_core is installed which does not define the
     # functions above. We do equivalent checks manually.
     try:

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/async_client.py

@@ -106,7 +106,7 @@ def from_service_account_info(cls, info: dict, *args, **kwargs):
         Returns:
             AssetServiceAsyncClient: The constructed client.
         """
-        return AssetServiceClient.from_service_account_info.__func__(AssetServiceAsyncClient, info, *args, **kwargs)  # type: ignore
+        return AssetServiceClient.from_service_account_info.__func__(AssetServiceAsyncClient, info, *args, **kwargs)  # type: ignore # fmt: skip
 
     @classmethod
     def from_service_account_file(cls, filename: str, *args, **kwargs):
@@ -122,7 +122,7 @@ def from_service_account_file(cls, filename: str, *args, **kwargs):
         Returns:
             AssetServiceAsyncClient: The constructed client.
         """
-        return AssetServiceClient.from_service_account_file.__func__(AssetServiceAsyncClient, filename, *args, **kwargs)  # type: ignore
+        return AssetServiceClient.from_service_account_file.__func__(AssetServiceAsyncClient, filename, *args, **kwargs)  # type: ignore # fmt: skip
 
     from_service_account_json = from_service_account_file
 
@@ -158,7 +158,7 @@ def get_mtls_endpoint_and_cert_source(cls, client_options: Optional[ClientOption
         Raises:
             google.auth.exceptions.MutualTLSChannelError: If any errors happen.
         """
-        return AssetServiceClient.get_mtls_endpoint_and_cert_source(client_options)  # type: ignore
+        return AssetServiceClient.get_mtls_endpoint_and_cert_source(client_options)  # type: ignore # fmt: skip
 
     @property
     def transport(self) -> AssetServiceTransport:
@@ -256,7 +256,7 @@ def __init__(self, *,
 
         )
 
-        if CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG):  # pragma: NO COVER
+        if CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG):  # pragma: NO COVER # fmt: skip
             _LOGGER.debug(
                 "Created client `google.cloud.asset_v1.AssetServiceAsyncClient`.",
                 extra = {
@@ -3212,7 +3212,7 @@ async def __aexit__(self, exc_type, exc, tb):
 
 DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(gapic_version=package_version.__version__)
 
-if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):   # pragma: NO COVER
+if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):   # pragma: NO COVER # fmt: skip
     DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
 
 

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/client.py

@@ -132,7 +132,7 @@ def _get_default_mtls_endpoint(api_endpoint):
 
     # Note: DEFAULT_ENDPOINT is deprecated. Use _DEFAULT_ENDPOINT_TEMPLATE instead.
     DEFAULT_ENDPOINT = "cloudasset.googleapis.com"
-    DEFAULT_MTLS_ENDPOINT = _get_default_mtls_endpoint.__func__(  # type: ignore
+    DEFAULT_MTLS_ENDPOINT = _get_default_mtls_endpoint.__func__(  # type: ignore # fmt: skip
         DEFAULT_ENDPOINT
     )
 
@@ -153,7 +153,7 @@ def _use_client_cert_effective():
 	    GOOGLE_API_USE_CLIENT_CERTIFICATE is set to an unexpected value.)
         """
         # check if google-auth version supports should_use_client_cert for automatic mTLS enablement
-        if hasattr(mtls, "should_use_client_cert"):  # pragma: NO COVER
+        if hasattr(mtls, "should_use_client_cert"):  # pragma: NO COVER # fmt: skip
             return mtls.should_use_client_cert()
         else: # pragma: NO COVER
             # if unsupported, fallback to reading from env var
@@ -624,7 +624,7 @@ def __init__(self, *,
         # Initialize the universe domain validation.
         self._is_universe_domain_valid = False
 
-        if CLIENT_LOGGING_SUPPORTED:  # pragma: NO COVER
+        if CLIENT_LOGGING_SUPPORTED:  # pragma: NO COVER # fmt: skip
             # Setup logging.
             client_logging.initialize_logging()
 
@@ -681,7 +681,7 @@ def __init__(self, *,
             )
 
         if "async" not in str(self._transport):
-            if CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG):  # pragma: NO COVER
+            if CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG):  # pragma: NO COVER # fmt: skip
                 _LOGGER.debug(
                     "Created client `google.cloud.asset_v1.AssetServiceClient`.",
                     extra = {
@@ -3640,7 +3640,7 @@ def get_operation(
 
 DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(gapic_version=package_version.__version__)
 
-if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):  # pragma: NO COVER
+if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):  # pragma: NO COVER # fmt: skip
     DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
 
 __all__ = (

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/transports/base.py

@@ -34,7 +34,7 @@
 
 DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(gapic_version=package_version.__version__)
 
-if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):  # pragma: NO COVER
+if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"):  # pragma: NO COVER # fmt: skip
     DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
 
 

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/transports/grpc.py

@@ -48,7 +48,7 @@
 class _LoggingClientInterceptor(grpc.UnaryUnaryClientInterceptor):  # pragma: NO COVER
     def intercept_unary_unary(self, continuation, client_call_details, request):
         logging_enabled = CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG)
-        if logging_enabled:  # pragma: NO COVER
+        if logging_enabled:  # pragma: NO COVER # fmt: skip
             request_metadata = client_call_details.metadata
             if isinstance(request, proto.Message):
                 request_payload = type(request).to_json(request)
@@ -76,7 +76,7 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 },
             )
         response = continuation(client_call_details, request)
-        if logging_enabled:  # pragma: NO COVER
+        if logging_enabled:  # pragma: NO COVER # fmt: skip
             response_metadata = response.trailing_metadata()
             # Convert gRPC metadata `<class 'grpc.aio._metadata.Metadata'>` to list of tuples
             metadata = dict([(k, str(v)) for k, v in response_metadata]) if response_metadata else None

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/transports/grpc_asyncio.py

@@ -52,7 +52,7 @@
 class _LoggingClientAIOInterceptor(grpc.aio.UnaryUnaryClientInterceptor):  # pragma: NO COVER
     async def intercept_unary_unary(self, continuation, client_call_details, request):
         logging_enabled = CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(std_logging.DEBUG)
-        if logging_enabled:  # pragma: NO COVER
+        if logging_enabled:  # pragma: NO COVER # fmt: skip
             request_metadata = client_call_details.metadata
             if isinstance(request, proto.Message):
                 request_payload = type(request).to_json(request)
@@ -80,7 +80,7 @@ async def intercept_unary_unary(self, continuation, client_call_details, request
                 },
             )
         response = await continuation(client_call_details, request)
-        if logging_enabled:  # pragma: NO COVER
+        if logging_enabled:  # pragma: NO COVER # fmt: skip
             response_metadata = await response.trailing_metadata()
             # Convert gRPC metadata `<class 'grpc.aio._metadata.Metadata'>` to list of tuples
             metadata = dict([(k, str(v)) for k, v in response_metadata]) if response_metadata else None
@@ -1213,7 +1213,7 @@ def _prep_wrapped_messages(self, client_info):
         }
 
     def _wrap_method(self, func, *args, **kwargs):
-        if self._wrap_with_kind:  # pragma: NO COVER
+        if self._wrap_with_kind:  # pragma: NO COVER # fmt: skip
             kwargs["kind"] = self.kind
         return gapic_v1.method_async.wrap_method(func, *args, **kwargs)