We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0188228 commit 902a4abCopy full SHA for 902a4ab
google/api_core/retry_async.py
@@ -241,12 +241,11 @@ async def retry_wrapped_func(*args, **kwargs):
241
242
@functools.wraps(func)
243
def retry_wrapped_stream(*args, deadline_dt=None, **kwargs):
244
- """A wrapper that yields through target generator with retry."""
+ """A wrapper that iterates over target stream with retry."""
245
target = functools.partial(func, *args, **kwargs)
246
sleep_generator = exponential_sleep_generator(
247
self._initial, self._maximum, multiplier=self._multiplier
248
)
249
- # if the target is a generator or iterable function, make sure return is also a generator function
250
return AsyncRetryableGenerator(
251
target,
252
self._predicate,
0 commit comments