ran blacken

Author: daniel-sanche

google/api_core/retry/retry_streaming.py

@@ -122,7 +122,14 @@ def retry_target_stream(
         except Exception as exc:
             # defer to shared logic for handling errors
             _retry_error_helper(
-                exc, deadline, sleep, error_list, predicate, on_error, exception_factory, timeout
+                exc,
+                deadline,
+                sleep,
+                error_list,
+                predicate,
+                on_error,
+                exception_factory,
+                timeout,
             )
             # if exception not raised, sleep before next attempt
             time.sleep(sleep)

google/api_core/retry/retry_streaming_async.py

@@ -175,7 +175,14 @@ async def retry_target_stream(
         except Exception as exc:
             # defer to shared logic for handling errors
             _retry_error_helper(
-                exc, deadline, sleep, error_list, predicate, on_error, exception_factory, timeout
+                exc,
+                deadline,
+                sleep,
+                error_list,
+                predicate,
+                on_error,
+                exception_factory,
+                timeout,
             )
             # if exception not raised, sleep before next attempt
             await asyncio.sleep(sleep)

google/api_core/retry/retry_unary.py

@@ -149,7 +149,14 @@ def retry_target(
         except Exception as exc:
             # defer to shared logic for handling errors
             _retry_error_helper(
-                exc, deadline, sleep, error_list, predicate, on_error, exception_factory, timeout
+                exc,
+                deadline,
+                sleep,
+                error_list,
+                predicate,
+                on_error,
+                exception_factory,
+                timeout,
             )
             # if exception not raised, sleep before next attempt
             time.sleep(sleep)

google/api_core/retry/retry_unary_async.py

@@ -155,7 +155,14 @@ async def retry_target(
         except Exception as exc:
             # defer to shared logic for handling errors
             _retry_error_helper(
-                exc, deadline, sleep, error_list, predicate, on_error, exception_factory, timeout
+                exc,
+                deadline,
+                sleep,
+                error_list,
+                predicate,
+                on_error,
+                exception_factory,
+                timeout,
             )
             # if exception not raised, sleep before next attempt
             await asyncio.sleep(sleep)