This repository was archived by the owner on Mar 31, 2026. It is now read-only.
Commit a3795a3
committed
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -143,11 +143,11 @@ async def mock_stream_opener(*args, **kwargs): | |||
| 143 | 143 | yield | |
| 144 | 144 | raise exceptions.ServiceUnavailable("Service is always down") | |
| 145 | 145 | ||
| 146 | - fast_retry = AsyncRetry(predicate=_is_retriable, deadline=0.01, initial=0.02) | ||
| 146 | + fast_retry = AsyncRetry(predicate=_is_retriable, deadline=0.1, initial=0.2) | ||
| 147 | 147 | retry_manager = manager._BidiStreamRetryManager( | |
| 148 | 148 | strategy=mock_strategy, stream_opener=mock_stream_opener | |
| 149 | 149 | ) | |
| 150 | - with pytest.raises(exceptions.RetryError, match="Timeout of 0.0s exceeded"): | ||
| 150 | + with pytest.raises(exceptions.RetryError, match="Timeout of 0.1s exceeded"): | ||
| 151 | 151 | await retry_manager.execute(initial_state={}, retry_policy=fast_retry) | |
| 152 | 152 | ||
| 153 | 153 | mock_strategy.recover_state_on_failure.assert_called_once() | |
0 commit comments