forma nox session with ruff

Author: ohmayr

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

@@ -111,6 +111,89 @@
     VersionedResource,
 )
 
+from .services.asset_service import AssetServiceAsyncClient, AssetServiceClient
+from .types.asset_service import (
+    AnalyzeIamPolicyLongrunningMetadata,
+    AnalyzeIamPolicyLongrunningRequest,
+    AnalyzeIamPolicyLongrunningResponse,
+    AnalyzeIamPolicyRequest,
+    AnalyzeIamPolicyResponse,
+    AnalyzeMoveRequest,
+    AnalyzeMoveResponse,
+    AnalyzeOrgPoliciesRequest,
+    AnalyzeOrgPoliciesResponse,
+    AnalyzeOrgPolicyGovernedAssetsRequest,
+    AnalyzeOrgPolicyGovernedAssetsResponse,
+    AnalyzeOrgPolicyGovernedContainersRequest,
+    AnalyzeOrgPolicyGovernedContainersResponse,
+    AnalyzerOrgPolicy,
+    AnalyzerOrgPolicyConstraint,
+    BatchGetAssetsHistoryRequest,
+    BatchGetAssetsHistoryResponse,
+    BatchGetEffectiveIamPoliciesRequest,
+    BatchGetEffectiveIamPoliciesResponse,
+    BigQueryDestination,
+    ContentType,
+    CreateFeedRequest,
+    CreateSavedQueryRequest,
+    DeleteFeedRequest,
+    DeleteSavedQueryRequest,
+    ExportAssetsRequest,
+    ExportAssetsResponse,
+    Feed,
+    FeedOutputConfig,
+    GcsDestination,
+    GcsOutputResult,
+    GetFeedRequest,
+    GetSavedQueryRequest,
+    IamPolicyAnalysisOutputConfig,
+    IamPolicyAnalysisQuery,
+    ListAssetsRequest,
+    ListAssetsResponse,
+    ListFeedsRequest,
+    ListFeedsResponse,
+    ListSavedQueriesRequest,
+    ListSavedQueriesResponse,
+    MoveAnalysis,
+    MoveAnalysisResult,
+    MoveImpact,
+    OutputConfig,
+    OutputResult,
+    PartitionSpec,
+    PubsubDestination,
+    QueryAssetsOutputConfig,
+    QueryAssetsRequest,
+    QueryAssetsResponse,
+    QueryResult,
+    SavedQuery,
+    SearchAllIamPoliciesRequest,
+    SearchAllIamPoliciesResponse,
+    SearchAllResourcesRequest,
+    SearchAllResourcesResponse,
+    TableFieldSchema,
+    TableSchema,
+    UpdateFeedRequest,
+    UpdateSavedQueryRequest,
+)
+from .types.assets import (
+    Asset,
+    AttachedResource,
+    ConditionEvaluation,
+    IamPolicyAnalysisResult,
+    IamPolicyAnalysisState,
+    IamPolicySearchResult,
+    RelatedAsset,
+    RelatedAssets,
+    RelatedResource,
+    RelatedResources,
+    RelationshipAttributes,
+    Resource,
+    ResourceSearchResult,
+    TemporalAsset,
+    TimeWindow,
+    VersionedResource,
+)
+
 if hasattr(api_core, "check_python_version") and hasattr(
     api_core, "check_dependency_versions"
 ):  # pragma: NO COVER

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

@@ -13,9 +13,9 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-from collections import OrderedDict
 import logging as std_logging
 import re
+from collections import OrderedDict
 from typing import (
     Callable,
     Dict,
@@ -29,13 +29,13 @@
     Union,
 )
 
+import google.protobuf
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1
 from google.api_core import retry_async as retries
 from google.api_core.client_options import ClientOptions
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
-import google.protobuf
 
 from google.cloud.asset_v1 import gapic_version as package_version
 
@@ -44,11 +44,15 @@
 except AttributeError:  # pragma: NO COVER
     OptionalRetry = Union[retries.AsyncRetry, object, None]  # type: ignore
 
-from google.api_core import operation  # type: ignore
-from google.api_core import operation_async  # type: ignore
+from google.api_core import (
+    operation,  # type: ignore
+    operation_async,  # type: ignore
+)
 from google.longrunning import operations_pb2  # type: ignore
-from google.protobuf import field_mask_pb2  # type: ignore
-from google.protobuf import timestamp_pb2  # type: ignore
+from google.protobuf import (
+    field_mask_pb2,  # type: ignore
+    timestamp_pb2,  # type: ignore
+)
 from google.rpc import status_pb2  # type: ignore
 from google.type import expr_pb2  # type: ignore
 
@@ -131,7 +135,9 @@ 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
 
     @classmethod
     def from_service_account_file(cls, filename: str, *args, **kwargs):
@@ -147,7 +153,9 @@ 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
 
     from_service_account_json = from_service_account_file
 

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

@@ -13,12 +13,13 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-from collections import OrderedDict
-from http import HTTPStatus
 import json
 import logging as std_logging
 import os
 import re
+import warnings
+from collections import OrderedDict
+from http import HTTPStatus
 from typing import (
     Callable,
     Dict,
@@ -32,8 +33,8 @@
     Union,
     cast,
 )
-import warnings
 
+import google.protobuf
 from google.api_core import client_options as client_options_lib
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1
@@ -43,7 +44,8 @@
 from google.auth.transport import mtls  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
-import google.protobuf
+
+from google.cloud.asset_v1 import gapic_version as package_version
 
 from google.cloud.asset_v1 import gapic_version as package_version
 
@@ -61,11 +63,15 @@
 
 _LOGGER = std_logging.getLogger(__name__)
 
-from google.api_core import operation  # type: ignore
-from google.api_core import operation_async  # type: ignore
+from google.api_core import (
+    operation,  # type: ignore
+    operation_async,  # type: ignore
+)
 from google.longrunning import operations_pb2  # type: ignore
-from google.protobuf import field_mask_pb2  # type: ignore
-from google.protobuf import timestamp_pb2  # type: ignore
+from google.protobuf import (
+    field_mask_pb2,  # type: ignore
+    timestamp_pb2,  # type: ignore
+)
 from google.rpc import status_pb2  # type: ignore
 from google.type import expr_pb2  # type: ignore
 
@@ -731,11 +737,9 @@ def __init__(
 
         universe_domain_opt = getattr(self._client_options, "universe_domain", None)
 
-        (
-            self._use_client_cert,
-            self._use_mtls_endpoint,
-            self._universe_domain_env,
-        ) = AssetServiceClient._read_environment_variables()
+        self._use_client_cert, self._use_mtls_endpoint, self._universe_domain_env = (
+            AssetServiceClient._read_environment_variables()
+        )
         self._client_cert_source = AssetServiceClient._get_client_cert_source(
             self._client_options.client_cert_source, self._use_client_cert
         )
@@ -770,8 +774,7 @@ def __init__(
                 )
             if self._client_options.scopes:
                 raise ValueError(
-                    "When providing a transport instance, provide its scopes "
-                    "directly."
+                    "When providing a transport instance, provide its scopes directly."
                 )
             self._transport = cast(AssetServiceTransport, transport)
             self._api_endpoint = self._transport.host

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

@@ -67,7 +67,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -143,7 +143,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -223,7 +223,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -299,7 +299,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -379,7 +379,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -455,7 +455,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -535,7 +535,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -611,7 +611,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -691,7 +691,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -769,7 +769,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -851,7 +851,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -935,7 +935,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 
@@ -1021,7 +1021,7 @@ def __init__(
         *,
         retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiate the pager.
 
@@ -1101,7 +1101,7 @@ def __init__(
         *,
         retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
-        metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
+        metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ):
         """Instantiates the pager.
 

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

@@ -17,14 +17,14 @@
 from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
 
 import google.api_core
+import google.auth  # type: ignore
+import google.protobuf
 from google.api_core import exceptions as core_exceptions
 from google.api_core import gapic_v1, operations_v1
 from google.api_core import retry as retries
-import google.auth  # type: ignore
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.longrunning import operations_pb2  # type: ignore
 from google.oauth2 import service_account  # type: ignore
-import google.protobuf
 from google.protobuf import empty_pb2  # type: ignore
 
 from google.cloud.asset_v1 import gapic_version as package_version