run black

Author: parthea

google/api_core/operations_v1/__init__.py

@@ -14,7 +14,9 @@
 
 """Package for interacting with the google.longrunning.operations meta-API."""
 
-from google.api_core.operations_v1.abstract_operations_client import AbstractOperationsClient
+from google.api_core.operations_v1.abstract_operations_client import (
+    AbstractOperationsClient,
+)
 from google.api_core.operations_v1.operations_async_client import OperationsAsyncClient
 from google.api_core.operations_v1.operations_client import OperationsClient
 from google.api_core.operations_v1.transports.rest import OperationsRestTransport
@@ -23,5 +25,5 @@
     "AbstractOperationsClient",
     "OperationsAsyncClient",
     "OperationsClient",
-    "OperationsRestTransport"
+    "OperationsRestTransport",
 ]

noxfile.py

@@ -139,7 +139,7 @@ def default(session, install_grpc=True, prerelease=False):
             ".[grpc]" if install_grpc else ".",
             "-c",
             f"{constraints_dir}/constraints-{session.python}.txt",
-            )
+        )
 
     # Print out package versions of dependencies
     session.run(

owlbot.py

@@ -29,8 +29,8 @@
     ".flake8",  # flake8-import-order, layout
     ".coveragerc",  # layout
     "CONTRIBUTING.rst",  # no systests
-    ".github/workflows/unittest.yml", # exclude unittest gh action
-    ".github/workflows/lint.yml", # exclude lint gh action
+    ".github/workflows/unittest.yml",  # exclude unittest gh action
+    ".github/workflows/lint.yml",  # exclude lint gh action
     "README.rst",
 ]
 templated_files = common.py_library(microgenerator=True, cov_level=100)

tests/unit/test_rest_streaming.py

@@ -101,9 +101,11 @@ def _parse_responses(self, responses: List[proto.Message]) -> bytes:
         # json.dumps returns a string surrounded with quotes that need to be stripped
         # in order to be an actual JSON.
         json_responses = [
-            self._response_message_cls.to_json(r).strip('"')
-            if issubclass(self._response_message_cls, proto.Message)
-            else MessageToJson(r).strip('"')
+            (
+                self._response_message_cls.to_json(r).strip('"')
+                if issubclass(self._response_message_cls, proto.Message)
+                else MessageToJson(r).strip('"')
+            )
             for r in responses
         ]
         logging.info(f"Sending JSON stream: {json_responses}")