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

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-analytics-data/.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-analytics-data/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-analytics-data/google/analytics/data_v1alpha/services/alpha_analytics_data/async_client.py

@@ -207,7 +207,12 @@ async def run_report(
         )
 
         # 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
@@ -255,7 +260,12 @@ async def run_pivot_report(
         )
 
         # 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
@@ -299,7 +309,12 @@ async def batch_run_reports(
         )
 
         # 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
@@ -343,7 +358,12 @@ async def batch_run_pivot_reports(
         )
 
         # 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
@@ -434,7 +454,12 @@ async def get_metadata(
         )
 
         # 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
@@ -486,15 +511,22 @@ async def run_realtime_report(
         )
 
         # 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
 
 
 try:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
-        gapic_version=pkg_resources.get_distribution("google-analytics-data",).version,
+        gapic_version=pkg_resources.get_distribution(
+            "google-analytics-data",
+        ).version,
     )
 except pkg_resources.DistributionNotFound:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo()

packages/google-analytics-data/google/analytics/data_v1alpha/services/alpha_analytics_data/client.py

@@ -52,7 +52,8 @@ class AlphaAnalyticsDataClientMeta(type):
     _transport_registry["grpc_asyncio"] = AlphaAnalyticsDataGrpcAsyncIOTransport
 
     def get_transport_class(
-        cls, label: str = None,
+        cls,
+        label: str = None,
     ) -> Type[AlphaAnalyticsDataTransport]:
         """Returns an appropriate transport class.
 
@@ -158,9 +159,13 @@ def transport(self) -> AlphaAnalyticsDataTransport:
         return self._transport
 
     @staticmethod
-    def metadata_path(property: str,) -> str:
+    def metadata_path(
+        property: str,
+    ) -> str:
         """Returns a fully-qualified metadata string."""
-        return "properties/{property}/metadata".format(property=property,)
+        return "properties/{property}/metadata".format(
+            property=property,
+        )
 
     @staticmethod
     def parse_metadata_path(path: str) -> Dict[str, str]:
@@ -169,7 +174,9 @@ def parse_metadata_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,
@@ -182,9 +189,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]:
@@ -193,9 +204,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]:
@@ -204,9 +219,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]:
@@ -215,10 +234,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
@@ -393,7 +416,12 @@ def run_report(
         rpc = self._transport._wrapped_methods[self._transport.run_report]
 
         # 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
@@ -442,7 +470,12 @@ def run_pivot_report(
         rpc = self._transport._wrapped_methods[self._transport.run_pivot_report]
 
         # 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
@@ -487,7 +520,12 @@ def batch_run_reports(
         rpc = self._transport._wrapped_methods[self._transport.batch_run_reports]
 
         # 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
@@ -532,7 +570,12 @@ def batch_run_pivot_reports(
         rpc = self._transport._wrapped_methods[self._transport.batch_run_pivot_reports]
 
         # 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
@@ -623,7 +666,12 @@ def get_metadata(
         )
 
         # 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
@@ -676,15 +724,22 @@ def run_realtime_report(
         )
 
         # 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
 
 
 try:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
-        gapic_version=pkg_resources.get_distribution("google-analytics-data",).version,
+        gapic_version=pkg_resources.get_distribution(
+            "google-analytics-data",
+        ).version,
     )
 except pkg_resources.DistributionNotFound:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo()

packages/google-analytics-data/google/analytics/data_v1alpha/services/alpha_analytics_data/transports/base.py

@@ -30,7 +30,9 @@
 
 try:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
-        gapic_version=pkg_resources.get_distribution("google-analytics-data",).version,
+        gapic_version=pkg_resources.get_distribution(
+            "google-analytics-data",
+        ).version,
     )
 except pkg_resources.DistributionNotFound:
     DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo()
@@ -156,24 +158,34 @@ def _prep_wrapped_messages(self, client_info):
         # Precompute the wrapped methods.
         self._wrapped_methods = {
             self.run_report: gapic_v1.method.wrap_method(
-                self.run_report, default_timeout=60.0, client_info=client_info,
+                self.run_report,
+                default_timeout=60.0,
+                client_info=client_info,
             ),
             self.run_pivot_report: gapic_v1.method.wrap_method(
-                self.run_pivot_report, default_timeout=60.0, client_info=client_info,
+                self.run_pivot_report,
+                default_timeout=60.0,
+                client_info=client_info,
             ),
             self.batch_run_reports: gapic_v1.method.wrap_method(
-                self.batch_run_reports, default_timeout=60.0, client_info=client_info,
+                self.batch_run_reports,
+                default_timeout=60.0,
+                client_info=client_info,
             ),
             self.batch_run_pivot_reports: gapic_v1.method.wrap_method(
                 self.batch_run_pivot_reports,
                 default_timeout=60.0,
                 client_info=client_info,
             ),
             self.get_metadata: gapic_v1.method.wrap_method(
-                self.get_metadata, default_timeout=None, client_info=client_info,
+                self.get_metadata,
+                default_timeout=None,
+                client_info=client_info,
             ),
             self.run_realtime_report: gapic_v1.method.wrap_method(
-                self.run_realtime_report, default_timeout=None, client_info=client_info,
+                self.run_realtime_report,
+                default_timeout=None,
+                client_info=client_info,
             ),
         }
 

packages/google-analytics-data/google/analytics/data_v1alpha/services/alpha_analytics_data/transports/grpc.py

@@ -221,8 +221,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