fixed style issues

Author: daniel-sanche

google/api_core/retry_streaming.py

@@ -105,7 +105,9 @@ def _handle_exception(self, exc) -> None:
             time.sleep(next_sleep)
             self.active_target = self.target_fn().__iter__()
 
-    def _check_timeout(self, current_time:float, source_exception: Optional[Exception] = None) -> None:
+    def _check_timeout(
+        self, current_time: float, source_exception: Optional[Exception] = None
+    ) -> None:
         """
         Helper function to check if the timeout has been exceeded, and raise a RetryError if so.
 
@@ -115,7 +117,11 @@ def _check_timeout(self, current_time:float, source_exception: Optional[Exceptio
         Raises:
           - RetryError if the deadline has been exceeded
         """
-        if self.deadline is not None and self.deadline < current_time:
+        if (
+            self.deadline is not None
+            and self.timeout is not None
+            and self.deadline < current_time
+        ):
             raise exceptions.RetryError(
                 "Timeout of {:.1f}s exceeded".format(self.timeout),
                 source_exception,

tests/asyncio/test_retry_async.py

@@ -776,4 +776,3 @@ async def test_iterate_stream_after_deadline(self):
             await generator.__anext__()
         with pytest.raises(exceptions.RetryError):
             await generator.asend("test")
-

tests/unit/test_retry.py

@@ -304,7 +304,7 @@ def test_with_delay_partial_options(self):
         assert retry_ is not new_retry
         assert new_retry._initial == 1
         assert new_retry._maximum == 4
-        assert n ew_retry._multiplier == 3
+        assert new_retry._multiplier == 3
 
         new_retry = retry_.with_delay(multiplier=4)
         assert retry_ is not new_retry
@@ -774,6 +774,7 @@ def test_iterate_stream_after_deadline(self):
         Streaming retries should raise RetryError when calling next after deadline has passed
         """
         from time import sleep
+
         retry_ = retry.Retry(
             predicate=retry.if_exception_type(ValueError),
             is_stream=True,
@@ -791,6 +792,7 @@ def test_iterate_stream_send_after_deadline(self):
         Streaming retries should raise RetryError when calling send after deadline has passed
         """
         from time import sleep
+
         retry_ = retry.Retry(
             predicate=retry.if_exception_type(ValueError),
             is_stream=True,
@@ -803,4 +805,3 @@ def test_iterate_stream_send_after_deadline(self):
         sleep(0.02)
         with pytest.raises(exceptions.RetryError):
             generator.send("test")
-