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

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

Author: gcf-owl-bot[bot]

packages/google-cloud-error-reporting/.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

packages/google-cloud-error-reporting/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),

packages/google-cloud-error-reporting/google/cloud/error_reporting/_gapic.py

@@ -66,8 +66,10 @@ def report_error_event(self, error_report):
         # Since error_report uses camel case for key names (like serviceContext),
         # but ReportedErrorEvent uses snake case for key names (like service_context),
         # we need to route throught json.
-        error_report_payload = google.cloud.errorreporting_v1beta1.ReportedErrorEvent.from_json(
-            json.dumps(error_report)
+        error_report_payload = (
+            google.cloud.errorreporting_v1beta1.ReportedErrorEvent.from_json(
+                json.dumps(error_report)
+            )
         )
 
         self._gapic_api.report_error_event(

packages/google-cloud-error-reporting/google/cloud/error_reporting/client.py

@@ -246,7 +246,7 @@ def _build_error_report(
         :rtype: dict
         :returns: A dict payload ready to be serialized to JSON and sent to
                   the API.
-         """
+        """
         payload = {
             "serviceContext": {"service": self.service},
             "message": "{0}".format(message),
@@ -315,7 +315,7 @@ def _send_error_report(
         self.report_errors_api.report_error_event(error_report)
 
     def report(self, message, http_context=None, user=None):
-        """ Reports a message to Error Reporting
+        """Reports a message to Error Reporting
 
         https://cloud.google.com/error-reporting/docs/formatting-error-messages
 
@@ -360,27 +360,27 @@ def report(self, message, http_context=None, user=None):
         )
 
     def report_exception(self, http_context=None, user=None):
-        """ Reports the details of the latest exceptions to Error Reporting.
-
-          :type http_context: :class`google.cloud.error_reporting.HTTPContext`
-          :param http_context: The HTTP request which was processed when the
-                               error was triggered.
-
-          :type user: str
-          :param user: The user who caused or was affected by the crash. This
-                       can be a user ID, an email address, or an arbitrary
-                       token that uniquely identifies the user. When sending an
-                       error report, leave this field empty if the user was
-                       not logged in. In this case the Error Reporting system
-                       will use other data, such as remote IP address,
-                       to distinguish affected users.
-
-           Example::
-
-                >>>     try:
-                >>>         raise NameError
-                >>>     except Exception:
-                >>>         client.report_exception()
+        """Reports the details of the latest exceptions to Error Reporting.
+
+        :type http_context: :class`google.cloud.error_reporting.HTTPContext`
+        :param http_context: The HTTP request which was processed when the
+                             error was triggered.
+
+        :type user: str
+        :param user: The user who caused or was affected by the crash. This
+                     can be a user ID, an email address, or an arbitrary
+                     token that uniquely identifies the user. When sending an
+                     error report, leave this field empty if the user was
+                     not logged in. In this case the Error Reporting system
+                     will use other data, such as remote IP address,
+                     to distinguish affected users.
+
+         Example::
+
+              >>>     try:
+              >>>         raise NameError
+              >>>     except Exception:
+              >>>         client.report_exception()
         """
         self._send_error_report(
             traceback.format_exc(), http_context=http_context, user=user

packages/google-cloud-error-reporting/google/cloud/errorreporting_v1beta1/services/error_group_service/async_client.py

@@ -295,7 +295,12 @@ def sample_get_group():
         )
 
         # Send the request.
-        response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # Done; return the response.
         return response
@@ -388,7 +393,12 @@ def sample_update_group():
         )
 
         # Send the request.
-        response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # Done; return the response.
         return response

packages/google-cloud-error-reporting/google/cloud/errorreporting_v1beta1/services/error_group_service/client.py

@@ -56,7 +56,8 @@ class ErrorGroupServiceClientMeta(type):
     _transport_registry["grpc_asyncio"] = ErrorGroupServiceGrpcAsyncIOTransport
 
     def get_transport_class(
-        cls, label: str = None,
+        cls,
+        label: str = None,
     ) -> Type[ErrorGroupServiceTransport]:
         """Returns an appropriate transport class.
 
@@ -162,9 +163,15 @@ def transport(self) -> ErrorGroupServiceTransport:
         return self._transport
 
     @staticmethod
-    def error_group_path(project: str, group: str,) -> str:
+    def error_group_path(
+        project: str,
+        group: str,
+    ) -> str:
         """Returns a fully-qualified error_group string."""
-        return "projects/{project}/groups/{group}".format(project=project, group=group,)
+        return "projects/{project}/groups/{group}".format(
+            project=project,
+            group=group,
+        )
 
     @staticmethod
     def parse_error_group_path(path: str) -> Dict[str, str]:
@@ -173,7 +180,9 @@ def parse_error_group_path(path: str) -> Dict[str, str]:
         return m.groupdict() if m else {}
 
     @staticmethod
-    def common_billing_account_path(billing_account: str,) -> str:
+    def common_billing_account_path(
+        billing_account: str,
+    ) -> str:
         """Returns a fully-qualified billing_account string."""
         return "billingAccounts/{billing_account}".format(
             billing_account=billing_account,
@@ -186,9 +195,13 @@ def parse_common_billing_account_path(path: str) -> Dict[str, str]:
         return m.groupdict() if m else {}
 
     @staticmethod
-    def common_folder_path(folder: str,) -> str:
+    def common_folder_path(
+        folder: str,
+    ) -> str:
         """Returns a fully-qualified folder string."""
-        return "folders/{folder}".format(folder=folder,)
+        return "folders/{folder}".format(
+            folder=folder,
+        )
 
     @staticmethod
     def parse_common_folder_path(path: str) -> Dict[str, str]:
@@ -197,9 +210,13 @@ def parse_common_folder_path(path: str) -> Dict[str, str]:
         return m.groupdict() if m else {}
 
     @staticmethod
-    def common_organization_path(organization: str,) -> str:
+    def common_organization_path(
+        organization: str,
+    ) -> str:
         """Returns a fully-qualified organization string."""
-        return "organizations/{organization}".format(organization=organization,)
+        return "organizations/{organization}".format(
+            organization=organization,
+        )
 
     @staticmethod
     def parse_common_organization_path(path: str) -> Dict[str, str]:
@@ -208,9 +225,13 @@ def parse_common_organization_path(path: str) -> Dict[str, str]:
         return m.groupdict() if m else {}
 
     @staticmethod
-    def common_project_path(project: str,) -> str:
+    def common_project_path(
+        project: str,
+    ) -> str:
         """Returns a fully-qualified project string."""
-        return "projects/{project}".format(project=project,)
+        return "projects/{project}".format(
+            project=project,
+        )
 
     @staticmethod
     def parse_common_project_path(path: str) -> Dict[str, str]:
@@ -219,10 +240,14 @@ def parse_common_project_path(path: str) -> Dict[str, str]:
         return m.groupdict() if m else {}
 
     @staticmethod
-    def common_location_path(project: str, location: str,) -> str:
+    def common_location_path(
+        project: str,
+        location: str,
+    ) -> str:
         """Returns a fully-qualified location string."""
         return "projects/{project}/locations/{location}".format(
-            project=project, location=location,
+            project=project,
+            location=location,
         )
 
     @staticmethod
@@ -487,7 +512,12 @@ def sample_get_group():
         )
 
         # Send the request.
-        response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # Done; return the response.
         return response
@@ -580,7 +610,12 @@ def sample_update_group():
         )
 
         # Send the request.
-        response = rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # Done; return the response.
         return response

packages/google-cloud-error-reporting/google/cloud/errorreporting_v1beta1/services/error_group_service/transports/base.py

@@ -122,19 +122,23 @@ def _prep_wrapped_messages(self, client_info):
         # Precompute the wrapped methods.
         self._wrapped_methods = {
             self.get_group: gapic_v1.method.wrap_method(
-                self.get_group, default_timeout=None, client_info=client_info,
+                self.get_group,
+                default_timeout=None,
+                client_info=client_info,
             ),
             self.update_group: gapic_v1.method.wrap_method(
-                self.update_group, default_timeout=None, client_info=client_info,
+                self.update_group,
+                default_timeout=None,
+                client_info=client_info,
             ),
         }
 
     def close(self):
         """Closes resources associated with the transport.
 
-       .. warning::
-            Only call this method if the transport is NOT shared
-            with other clients - this may cause errors in other clients!
+        .. warning::
+             Only call this method if the transport is NOT shared
+             with other clients - this may cause errors in other clients!
         """
         raise NotImplementedError()
 

packages/google-cloud-error-reporting/google/cloud/errorreporting_v1beta1/services/error_group_service/transports/grpc.py

@@ -225,8 +225,7 @@ def create_channel(
 
     @property
     def grpc_channel(self) -> grpc.Channel:
-        """Return the channel designed to connect to this service.
-        """
+        """Return the channel designed to connect to this service."""
         return self._grpc_channel
 
     @property

packages/google-cloud-error-reporting/google/cloud/errorreporting_v1beta1/services/error_stats_service/async_client.py

@@ -320,12 +320,20 @@ def sample_list_group_stats():
         )
 
         # Send the request.
-        response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # This method is paged; wrap the response in a pager, which provides
         # an `__aiter__` convenience method.
         response = pagers.ListGroupStatsAsyncPager(
-            method=rpc, request=request, response=response, metadata=metadata,
+            method=rpc,
+            request=request,
+            response=response,
+            metadata=metadata,
         )
 
         # Done; return the response.
@@ -437,12 +445,20 @@ def sample_list_events():
         )
 
         # Send the request.
-        response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # This method is paged; wrap the response in a pager, which provides
         # an `__aiter__` convenience method.
         response = pagers.ListEventsAsyncPager(
-            method=rpc, request=request, response=response, metadata=metadata,
+            method=rpc,
+            request=request,
+            response=response,
+            metadata=metadata,
         )
 
         # Done; return the response.
@@ -538,7 +554,12 @@ def sample_delete_events():
         )
 
         # Send the request.
-        response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
 
         # Done; return the response.
         return response