chore(python): use black==22.3.0 (#545)

Source-Link: googleapis/synthtool@6fab84a
Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe

.github/.OwlBot.lock.yaml

@@ -13,4 +13,4 @@
 # limitations under the License.
 docker:
   image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
-  digest: sha256:4e1991042fe54b991db9ca17c8fb386e61b22fe4d1472a568bf0fcac85dcf5d3
+  digest: sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe

docs/conf.py

@@ -361,7 +361,10 @@
 intersphinx_mapping = {
     "python": ("https://python.readthedocs.org/en/latest/", None),
     "google-auth": ("https://googleapis.dev/python/google-auth/latest/", None),
-    "google.api_core": ("https://googleapis.dev/python/google-api-core/latest/", None,),
+    "google.api_core": (
+        "https://googleapis.dev/python/google-api-core/latest/",
+        None,
+    ),
     "grpc": ("https://grpc.github.io/grpc/python/", None),
     "proto-plus": ("https://proto-plus-python.readthedocs.io/en/latest/", None),
     "protobuf": ("https://googleapis.dev/python/protobuf/latest/", None),

docs/snippets.py

@@ -55,7 +55,7 @@
 PRODUCTION = enums.Instance.Type.PRODUCTION
 SERVER_NODES = 3
 STORAGE_TYPE = enums.StorageType.SSD
-LABEL_KEY = u"python-snippet"
+LABEL_KEY = "python-snippet"
 LABEL_STAMP = (
     datetime.datetime.utcnow()
     .replace(microsecond=0, tzinfo=UTC)

docs/snippets_table.py

@@ -52,7 +52,7 @@
 PRODUCTION = enums.Instance.Type.PRODUCTION
 SERVER_NODES = 3
 STORAGE_TYPE = enums.StorageType.SSD
-LABEL_KEY = u"python-snippet"
+LABEL_KEY = "python-snippet"
 LABEL_STAMP = (
     datetime.datetime.utcnow()
     .replace(microsecond=0, tzinfo=UTC)

google/cloud/bigtable/backup.py

@@ -382,7 +382,8 @@ def update_expire_time(self, new_expire_time):
         :param new_expire_time: the new expiration time timestamp
         """
         backup_update = table.Backup(
-            name=self.name, expire_time=_datetime_to_pb_timestamp(new_expire_time),
+            name=self.name,
+            expire_time=_datetime_to_pb_timestamp(new_expire_time),
         )
         update_mask = field_mask_pb2.FieldMask(paths=["expire_time"])
         api = self._instance._client.table_admin_client
@@ -426,7 +427,8 @@ def restore(self, table_id, instance_id=None):
         api = self._instance._client.table_admin_client
         if instance_id:
             parent = BigtableTableAdminClient.instance_path(
-                project=self._instance._client.project, instance=instance_id,
+                project=self._instance._client.project,
+                instance=instance_id,
             )
         else:
             parent = self._instance.name

google/cloud/bigtable/client.py

@@ -193,7 +193,9 @@ def __init__(
         self._channel = channel
         self.SCOPE = self._get_scopes()
         super(Client, self).__init__(
-            project=project, credentials=credentials, client_options=client_options,
+            project=project,
+            credentials=credentials,
+            client_options=client_options,
         )
 
     def _get_scopes(self):
@@ -276,7 +278,8 @@ def _create_gapic_client_channel(self, client_class, grpc_transport):
 
         if self._emulator_host is not None:
             channel = self._emulator_channel(
-                transport=grpc_transport, options=_GRPC_CHANNEL_OPTIONS,
+                transport=grpc_transport,
+                options=_GRPC_CHANNEL_OPTIONS,
             )
         else:
             channel = grpc_transport.create_channel(
@@ -327,7 +330,8 @@ def table_data_client(self):
         """
         if self._table_data_client is None:
             transport = self._create_gapic_client_channel(
-                bigtable_v2.BigtableClient, BigtableGrpcTransport,
+                bigtable_v2.BigtableClient,
+                BigtableGrpcTransport,
             )
             klass = _create_gapic_client(
                 bigtable_v2.BigtableClient,

google/cloud/bigtable/cluster.py

@@ -509,7 +509,7 @@ def delete(self):
         client.instance_admin_client.delete_cluster(request={"name": self.name})
 
     def _to_pb(self):
-        """ Create cluster proto buff message for API calls """
+        """Create cluster proto buff message for API calls"""
         client = self._instance._client
         location = client.instance_admin_client.common_location_path(
             client.project, self.location_id

google/cloud/bigtable/row_data.py

@@ -649,15 +649,15 @@ def build_updated_request(self):
         return resume_request
 
     def _filter_rows_keys(self):
-        """ Helper for :meth:`build_updated_request`"""
+        """Helper for :meth:`build_updated_request`"""
         return [
             row_key
             for row_key in self.message.rows.row_keys
             if row_key > self.last_scanned_key
         ]
 
     def _filter_row_ranges(self):
-        """ Helper for :meth:`build_updated_request`"""
+        """Helper for :meth:`build_updated_request`"""
         new_row_ranges = []
 
         for row_range in self.message.rows.row_ranges:
@@ -688,17 +688,17 @@ def _filter_row_ranges(self):
         return new_row_ranges
 
     def _key_already_read(self, key):
-        """ Helper for :meth:`_filter_row_ranges`"""
+        """Helper for :meth:`_filter_row_ranges`"""
         return key <= self.last_scanned_key
 
     @staticmethod
     def _start_key_set(row_range):
-        """ Helper for :meth:`_filter_row_ranges`"""
+        """Helper for :meth:`_filter_row_ranges`"""
         return row_range.start_key_open or row_range.start_key_closed
 
     @staticmethod
     def _end_key_set(row_range):
-        """ Helper for :meth:`_filter_row_ranges`"""
+        """Helper for :meth:`_filter_row_ranges`"""
         return row_range.end_key_open or row_range.end_key_closed