blacken all gen'd libs

asset/google/__init__.py

@@ -16,7 +16,9 @@
 
 try:
     import pkg_resources
+
     pkg_resources.declare_namespace(__name__)
 except ImportError:
     import pkgutil
+
     __path__ = pkgutil.extend_path(__path__, __name__)

asset/google/cloud/__init__.py

@@ -16,7 +16,9 @@
 
 try:
     import pkg_resources
+
     pkg_resources.declare_namespace(__name__)
 except ImportError:
     import pkgutil
+
     __path__ = pkgutil.extend_path(__path__, __name__)

asset/google/cloud/asset.py

@@ -20,8 +20,4 @@
 from google.cloud.asset_v1beta1 import enums
 from google.cloud.asset_v1beta1 import types
 
-__all__ = (
-    'enums',
-    'types',
-    'AssetServiceClient',
-)
+__all__ = ("enums", "types", "AssetServiceClient")

asset/google/cloud/asset_v1beta1/__init__.py

@@ -26,8 +26,4 @@ class AssetServiceClient(asset_service_client.AssetServiceClient):
     enums = enums
 
 
-__all__ = (
-    'enums',
-    'types',
-    'AssetServiceClient',
-)
+__all__ = ("enums", "types", "AssetServiceClient")

asset/google/cloud/asset_v1beta1/gapic/asset_service_client.py

@@ -37,19 +37,18 @@
 from google.longrunning import operations_pb2
 from google.protobuf import timestamp_pb2
 
-_GAPIC_LIBRARY_VERSION = pkg_resources.get_distribution(
-    'google-cloud-asset', ).version
+_GAPIC_LIBRARY_VERSION = pkg_resources.get_distribution("google-cloud-asset").version
 
 
 class AssetServiceClient(object):
     """Asset service definition."""
 
-    SERVICE_ADDRESS = 'cloudasset.googleapis.com:443'
+    SERVICE_ADDRESS = "cloudasset.googleapis.com:443"
     """The default address of the service."""
 
     # The name of the interface for this client. This is the key used to
     # find the method configuration in the client_config dictionary.
-    _INTERFACE_NAME = 'google.cloud.asset.v1beta1.AssetService'
+    _INTERFACE_NAME = "google.cloud.asset.v1beta1.AssetService"
 
     @classmethod
     def from_service_account_file(cls, filename, *args, **kwargs):
@@ -65,9 +64,8 @@ def from_service_account_file(cls, filename, *args, **kwargs):
         Returns:
             AssetServiceClient: The constructed client.
         """
-        credentials = service_account.Credentials.from_service_account_file(
-            filename)
-        kwargs['credentials'] = credentials
+        credentials = service_account.Credentials.from_service_account_file(filename)
+        kwargs["credentials"] = credentials
         return cls(*args, **kwargs)
 
     from_service_account_json = from_service_account_file
@@ -76,16 +74,17 @@ def from_service_account_file(cls, filename, *args, **kwargs):
     def project_path(cls, project):
         """Return a fully-qualified project string."""
         return google.api_core.path_template.expand(
-            'projects/{project}',
-            project=project,
+            "projects/{project}", project=project
         )
 
-    def __init__(self,
-                 transport=None,
-                 channel=None,
-                 credentials=None,
-                 client_config=None,
-                 client_info=None):
+    def __init__(
+        self,
+        transport=None,
+        channel=None,
+        credentials=None,
+        client_config=None,
+        client_info=None,
+    ):
         """Constructor.
 
         Args:
@@ -119,18 +118,19 @@ def __init__(self,
         # Raise deprecation warnings for things we want to go away.
         if client_config is not None:
             warnings.warn(
-                'The `client_config` argument is deprecated.',
+                "The `client_config` argument is deprecated.",
                 PendingDeprecationWarning,
-                stacklevel=2)
+                stacklevel=2,
+            )
         else:
             client_config = asset_service_client_config.config
 
         if channel:
             warnings.warn(
-                'The `channel` argument is deprecated; use '
-                '`transport` instead.',
+                "The `channel` argument is deprecated; use " "`transport` instead.",
                 PendingDeprecationWarning,
-                stacklevel=2)
+                stacklevel=2,
+            )
 
         # Instantiate the transport.
         # The transport is responsible for handling serialization and
@@ -139,25 +139,24 @@ def __init__(self,
             if callable(transport):
                 self.transport = transport(
                     credentials=credentials,
-                    default_class=asset_service_grpc_transport.
-                    AssetServiceGrpcTransport,
+                    default_class=asset_service_grpc_transport.AssetServiceGrpcTransport,
                 )
             else:
                 if credentials:
                     raise ValueError(
-                        'Received both a transport instance and '
-                        'credentials; these are mutually exclusive.')
+                        "Received both a transport instance and "
+                        "credentials; these are mutually exclusive."
+                    )
                 self.transport = transport
         else:
             self.transport = asset_service_grpc_transport.AssetServiceGrpcTransport(
-                address=self.SERVICE_ADDRESS,
-                channel=channel,
-                credentials=credentials,
+                address=self.SERVICE_ADDRESS, channel=channel, credentials=credentials
             )
 
         if client_info is None:
             client_info = google.api_core.gapic_v1.client_info.ClientInfo(
-                gapic_version=_GAPIC_LIBRARY_VERSION, )
+                gapic_version=_GAPIC_LIBRARY_VERSION
+            )
         else:
             client_info.gapic_version = _GAPIC_LIBRARY_VERSION
         self._client_info = client_info
@@ -167,7 +166,8 @@ def __init__(self,
         # (Ordinarily, these are the defaults specified in the `*_config.py`
         # file next to this one.)
         self._method_configs = google.api_core.gapic_v1.config.parse_method_configs(
-            client_config['interfaces'][self._INTERFACE_NAME], )
+            client_config["interfaces"][self._INTERFACE_NAME]
+        )
 
         # Save a dictionary of cached API call functions.
         # These are the actual callables which invoke the proper
@@ -176,15 +176,17 @@ def __init__(self,
         self._inner_api_calls = {}
 
     # Service calls
-    def export_assets(self,
-                      parent,
-                      output_config,
-                      read_time=None,
-                      asset_types=None,
-                      content_type=None,
-                      retry=google.api_core.gapic_v1.method.DEFAULT,
-                      timeout=google.api_core.gapic_v1.method.DEFAULT,
-                      metadata=None):
+    def export_assets(
+        self,
+        parent,
+        output_config,
+        read_time=None,
+        asset_types=None,
+        content_type=None,
+        retry=google.api_core.gapic_v1.method.DEFAULT,
+        timeout=google.api_core.gapic_v1.method.DEFAULT,
+        metadata=None,
+    ):
         """
         Exports assets with time and resource types to a given Cloud Storage
         location. The output format is newline-delimited JSON. This API
@@ -253,15 +255,15 @@ def export_assets(self,
             ValueError: If the parameters are invalid.
         """
         # Wrap the transport method to add retry and timeout logic.
-        if 'export_assets' not in self._inner_api_calls:
+        if "export_assets" not in self._inner_api_calls:
             self._inner_api_calls[
-                'export_assets'] = google.api_core.gapic_v1.method.wrap_method(
-                    self.transport.export_assets,
-                    default_retry=self._method_configs['ExportAssets'].retry,
-                    default_timeout=self._method_configs['ExportAssets'].
-                    timeout,
-                    client_info=self._client_info,
-                )
+                "export_assets"
+            ] = google.api_core.gapic_v1.method.wrap_method(
+                self.transport.export_assets,
+                default_retry=self._method_configs["ExportAssets"].retry,
+                default_timeout=self._method_configs["ExportAssets"].timeout,
+                client_info=self._client_info,
+            )
 
         request = asset_service_pb2.ExportAssetsRequest(
             parent=parent,
@@ -270,8 +272,9 @@ def export_assets(self,
             asset_types=asset_types,
             content_type=content_type,
         )
-        operation = self._inner_api_calls['export_assets'](
-            request, retry=retry, timeout=timeout, metadata=metadata)
+        operation = self._inner_api_calls["export_assets"](
+            request, retry=retry, timeout=timeout, metadata=metadata
+        )
         return google.api_core.operation.from_gapic(
             operation,
             self.transport._operations_client,
@@ -280,14 +283,15 @@ def export_assets(self,
         )
 
     def batch_get_assets_history(
-            self,
-            parent,
-            content_type,
-            read_time_window,
-            asset_names=None,
-            retry=google.api_core.gapic_v1.method.DEFAULT,
-            timeout=google.api_core.gapic_v1.method.DEFAULT,
-            metadata=None):
+        self,
+        parent,
+        content_type,
+        read_time_window,
+        asset_names=None,
+        retry=google.api_core.gapic_v1.method.DEFAULT,
+        timeout=google.api_core.gapic_v1.method.DEFAULT,
+        metadata=None,
+    ):
         """
         Batch gets the update history of assets that overlap a time window. For
         RESOURCE content, this API outputs history with asset in both non-delete
@@ -350,22 +354,22 @@ def batch_get_assets_history(
             ValueError: If the parameters are invalid.
         """
         # Wrap the transport method to add retry and timeout logic.
-        if 'batch_get_assets_history' not in self._inner_api_calls:
+        if "batch_get_assets_history" not in self._inner_api_calls:
             self._inner_api_calls[
-                'batch_get_assets_history'] = google.api_core.gapic_v1.method.wrap_method(
-                    self.transport.batch_get_assets_history,
-                    default_retry=self.
-                    _method_configs['BatchGetAssetsHistory'].retry,
-                    default_timeout=self.
-                    _method_configs['BatchGetAssetsHistory'].timeout,
-                    client_info=self._client_info,
-                )
+                "batch_get_assets_history"
+            ] = google.api_core.gapic_v1.method.wrap_method(
+                self.transport.batch_get_assets_history,
+                default_retry=self._method_configs["BatchGetAssetsHistory"].retry,
+                default_timeout=self._method_configs["BatchGetAssetsHistory"].timeout,
+                client_info=self._client_info,
+            )
 
         request = asset_service_pb2.BatchGetAssetsHistoryRequest(
             parent=parent,
             content_type=content_type,
             read_time_window=read_time_window,
             asset_names=asset_names,
         )
-        return self._inner_api_calls['batch_get_assets_history'](
-            request, retry=retry, timeout=timeout, metadata=metadata)
+        return self._inner_api_calls["batch_get_assets_history"](
+            request, retry=retry, timeout=timeout, metadata=metadata
+        )

asset/google/cloud/asset_v1beta1/gapic/asset_service_client_config.py

@@ -3,7 +3,7 @@
         "google.cloud.asset.v1beta1.AssetService": {
             "retry_codes": {
                 "idempotent": ["DEADLINE_EXCEEDED", "UNAVAILABLE"],
-                "non_idempotent": []
+                "non_idempotent": [],
             },
             "retry_params": {
                 "default": {
@@ -13,21 +13,21 @@
                     "initial_rpc_timeout_millis": 20000,
                     "rpc_timeout_multiplier": 1.0,
                     "max_rpc_timeout_millis": 20000,
-                    "total_timeout_millis": 600000
+                    "total_timeout_millis": 600000,
                 }
             },
             "methods": {
                 "ExportAssets": {
                     "timeout_millis": 600000,
                     "retry_codes_name": "non_idempotent",
-                    "retry_params_name": "default"
+                    "retry_params_name": "default",
                 },
                 "BatchGetAssetsHistory": {
                     "timeout_millis": 600000,
                     "retry_codes_name": "idempotent",
-                    "retry_params_name": "default"
-                }
-            }
+                    "retry_params_name": "default",
+                },
+            },
         }
     }
 }

asset/google/cloud/asset_v1beta1/gapic/enums.py

@@ -28,6 +28,7 @@ class NullValue(enum.IntEnum):
     Attributes:
       NULL_VALUE (int): Null value.
     """
+
     NULL_VALUE = 0
 
 
@@ -40,6 +41,7 @@ class ContentType(enum.IntEnum):
       RESOURCE (int): Resource metadata.
       IAM_POLICY (int): The actual IAM policy set on a resource.
     """
+
     CONTENT_TYPE_UNSPECIFIED = 0
     RESOURCE = 1
     IAM_POLICY = 2