fix unit tests

Author: Pulkit0110

google/cloud/storage/_experimental/asyncio/retry/bidi_stream_retry_manager.py

@@ -58,4 +58,4 @@ async def attempt():
 
         wrapped_attempt = retry_policy(attempt)
 
-        await wrapped_attempt()
+        await wrapped_attempt()

tests/unit/asyncio/retry/test_bidi_stream_retry_manager.py

@@ -143,14 +143,28 @@ async def mock_stream_opener(*args, **kwargs):
                 yield
             raise exceptions.ServiceUnavailable("Service is always down")
 
-        fast_retry = AsyncRetry(predicate=_is_retriable, deadline=0.1, initial=0.2)
+        fast_retry = AsyncRetry(
+            predicate=_is_retriable, deadline=1, initial=0.6, multiplier=1.5
+        )
         retry_manager = manager._BidiStreamRetryManager(
             strategy=mock_strategy, stream_opener=mock_stream_opener
         )
-        with pytest.raises(exceptions.RetryError, match="Timeout of 0.1s exceeded"):
-            await retry_manager.execute(initial_state={}, retry_policy=fast_retry)
 
-        mock_strategy.recover_state_on_failure.assert_called_once()
+        now = 0
+
+        def monotonic_mock():
+            return now
+
+        async def sleep_mock(delay):
+            nonlocal now
+            now += delay
+
+        with mock.patch("time.monotonic", new=monotonic_mock):
+            with mock.patch("asyncio.sleep", new=sleep_mock):
+                with pytest.raises(exceptions.RetryError):
+                    await retry_manager.execute(initial_state={}, retry_policy=fast_retry)
+
+        assert mock_strategy.recover_state_on_failure.call_count == 2
 
     @pytest.mark.asyncio
     async def test_execute_fails_immediately_on_non_retriable_error(self):