| /external/python/python-api-core/google/api_core/gapic_v1/ |
| D | method.py | 17 This is used by gapic clients to provide common error mapping, retry, timeout,
41 """Sentinel value indicating that a retry or timeout argument was unspecified,
63 def _determine_timeout(default_timeout, specified_timeout, retry): argument
72 retry (Optional[Retry]): The retry specified at invocation time.
89 # a non-default retry is specified, make sure the timeout's deadline
90 # matches the retry's. This handles the case where the user leaves
91 # the timeout default but specifies a lower deadline via the retry.
93 retry
94 and retry is not DEFAULT
97 return default_timeout.with_deadline(retry._deadline)
[all …]
|
| D | config.py | 26 from google.api_core import retry
47 def _retry_from_retry_config(retry_params, retry_codes, retry_impl=retry.Retry):
48 """Creates a Retry object given a gapic retry configuration.
51 retry_params (dict): The retry parameter values, for example::
67 google.api_core.retry.Retry: The default retry object for the method.
73 retry.if_exception_type(*exception_classes),
82 """Creates a ExponentialTimeout object given a gapic retry configuration.
85 retry_params (dict): The retry parameter values, for example::
98 google.api_core.retry.ExponentialTimeout: The default time object for
109 MethodConfig = collections.namedtuple("MethodConfig", ["retry", "timeout"])
[all …]
|
| /external/python/python-api-core/google/api_core/ |
| D | retry.py | 17 The :class:`Retry` decorator can be used to retry functions that raise
19 used, the retry is limited by a `deadline`. The deadline is the maxmimum amount
24 By default, this decorator will retry transient
29 @retry.Retry()
33 # Will retry flaky_rpc() if it raises transient API errors.
36 You can pass a custom predicate to retry on different exceptions, such as
41 @retry.Retry(predicate=if_exception_type(exceptions.NotFound))
47 Some client library methods apply retry automatically. These methods can accept
48 a ``retry`` parameter that allows you to configure the behavior:
52 my_retry = retry.Retry(deadline=60)
[all …]
|
| D | retry_async.py | 18 :class:`Retry`, but supports coroutine functions. Please refer to description
19 of :class:`Retry` for more details.
21 By default, this decorator will retry transient
30 # Will retry flaky_rpc() if it raises transient API errors.
33 You can pass a custom predicate to retry on different exceptions, such as
44 Some client library methods apply retry automatically. These methods can accept
45 a ``retry`` parameter that allows you to configure the behavior:
50 result = await client.some_method(retry=my_retry)
61 from google.api_core.retry import exponential_sleep_generator
62 from google.api_core.retry import if_exception_type # noqa: F401
[all …]
|
| D | operation.py | 64 retry (google.api_core.retry.Retry): The retry configuration used
66 is polled. Regardless of the retry's ``deadline``, it will be
77 retry=polling.DEFAULT_RETRY, argument
79 super(Operation, self).__init__(retry=retry)
149 def _refresh_and_update(self, retry=polling.DEFAULT_RETRY): argument
153 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
158 self._operation = self._refresh(retry=retry)
161 def done(self, retry=polling.DEFAULT_RETRY): argument
165 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
170 self._refresh_and_update(retry)
[all …]
|
| D | operation_async.py | 63 retry (google.api_core.retry.Retry): The retry configuration used
65 is polled. Regardless of the retry's ``deadline``, it will be
76 retry=async_future.DEFAULT_RETRY, argument
78 super().__init__(retry=retry)
145 async def _refresh_and_update(self, retry=async_future.DEFAULT_RETRY): argument
149 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
154 self._operation = await self._refresh(retry=retry)
157 async def done(self, retry=async_future.DEFAULT_RETRY): argument
161 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
166 await self._refresh_and_update(retry)
|
| /external/python/python-api-core/google/api_core/operations_v1/ |
| D | operations_client.py | 62 # The interface config contains all of the default settings for retry
70 default_retry=method_configs["GetOperation"].retry,
76 default_retry=method_configs["ListOperations"].retry,
82 default_retry=method_configs["CancelOperation"].retry,
88 default_retry=method_configs["DeleteOperation"].retry,
96 retry=gapic_v1.method.DEFAULT, argument
113 retry (google.api_core.retry.Retry): The retry strategy to use
114 when invoking the RPC. If unspecified, the default retry from
116 method will not retry the RPC at all.
118 to complete. Note that if ``retry`` is used, this timeout
[all …]
|
| D | operations_async_client.py | 49 # The interface config contains all of the default settings for retry
57 default_retry=method_configs["GetOperation"].retry,
63 default_retry=method_configs["ListOperations"].retry,
69 default_retry=method_configs["CancelOperation"].retry,
75 default_retry=method_configs["DeleteOperation"].retry,
82 retry=gapic_v1.method_async.DEFAULT, argument
99 retry (google.api_core.retry.Retry): The retry strategy to use
100 when invoking the RPC. If unspecified, the default retry from
102 method will not retry the RPC at all.
104 to complete. Note that if ``retry`` is used, this timeout
[all …]
|
| /external/python/python-api-core/tests/unit/ |
| D | test_retry.py | 24 from google.api_core import retry
29 predicate = retry.if_exception_type(ValueError)
36 predicate = retry.if_exception_type(ValueError, TypeError)
44 assert retry.if_transient_error(exceptions.InternalServerError(""))
45 assert retry.if_transient_error(exceptions.TooManyRequests(""))
46 assert retry.if_transient_error(exceptions.ServiceUnavailable(""))
47 assert retry.if_transient_error(requests.exceptions.ConnectionError(""))
48 assert retry.if_transient_error(requests.exceptions.ChunkedEncodingError(""))
49 assert retry.if_transient_error(auth_exceptions.TransportError(""))
50 assert not retry.if_transient_error(exceptions.InvalidArgument(""))
[all …]
|
| D | test_operation.py | 27 from google.api_core import retry
125 RETRY_PREDICATE = retry.if_exception_type(exceptions.TooManyRequests)
126 test_retry = retry.Retry(predicate=RETRY_PREDICATE)
137 future.done(retry=test_retry)
138 future._refresh.assert_called_once_with(retry=test_retry)
203 retry = mock.Mock()
204 retry.return_value.return_value = json_response
206 result = operation._refresh_http(api_request, TEST_OPERATION_NAME, retry=retry)
213 retry.assert_called_once_with(api_request)
214 retry.return_value.assert_called_once_with(
[all …]
|
| /external/python/python-api-core/google/api_core/future/ |
| D | polling.py | 21 from google.api_core import retry
27 """Private exception used for polling via retry."""
32 RETRY_PREDICATE = retry.if_exception_type(
39 DEFAULT_RETRY = retry.Retry(predicate=RETRY_PREDICATE)
54 retry (google.api_core.retry.Retry): The retry configuration used
56 is polled. Regardless of the retry's ``deadline``, it will be
60 def __init__(self, retry=DEFAULT_RETRY): argument
62 self._retry = retry
72 def done(self, retry=DEFAULT_RETRY): argument
76 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
[all …]
|
| D | async_future.py | 20 from google.api_core import retry
26 """Private exception used for polling via retry."""
31 RETRY_PREDICATE = retry.if_exception_type(
52 retry (google.api_core.retry.Retry): The retry configuration used
54 is polled. Regardless of the retry's ``deadline``, it will be
58 def __init__(self, retry=DEFAULT_RETRY): argument
60 self._retry = retry
64 async def done(self, retry=DEFAULT_RETRY): argument
68 retry (google.api_core.retry.Retry): (Optional) How to retry the RPC.
|
| /external/autotest/client/common_lib/cros/ |
| D | retry_unittest.py | 5 """Unit tests for client/common_lib/cros/retry.py."""
15 from autotest_lib.client.common_lib.cros import retry
20 """Unit tests for retry decorators.
41 @retry.retry(Exception)
48 """Test that a wrapped function can retry and succeed."""
52 @retry.retry(Exception, delay_sec=delay_sec)
65 @retry.retry(Exception, delay_sec=delay_sec)
71 """Test that dynamic_suite exceptions raise immediately, no retry."""
72 @retry.retry(Exception)
79 """Unit tests for retry decorators with real sleep."""
[all …]
|
| /external/cronet/buildtools/third_party/libc++/trunk/utils/ci/ |
| D | buildkite-pipeline.yml | 45 retry:
63 retry:
79 retry:
104 retry:
122 retry:
140 retry:
158 retry:
176 retry:
199 retry:
217 retry:
[all …]
|
| /external/python/python-api-core/tests/unit/gapic/ |
| D | test_config.py | 71 retry, timeout = method_configs["AnnotateVideo"]
72 assert retry._predicate(exceptions.DeadlineExceeded(None))
73 assert retry._predicate(exceptions.ServiceUnavailable(None))
74 assert retry._initial == 1.0
75 assert retry._multiplier == 2.5
76 assert retry._maximum == 120.0
77 assert retry._deadline == 600.0
82 retry, timeout = method_configs["Other"]
83 assert retry._predicate(exceptions.FailedPrecondition(None))
84 assert retry._initial == 1.0
[all …]
|
| D | test_method.py | 27 from google.api_core import retry
149 default_retry = retry.Retry()
167 default_retry = retry.Retry()
174 retry=google.api_core.gapic_v1.method.DEFAULT,
186 default_retry = retry.Retry()
193 retry=retry.Retry(retry.if_exception_type(exceptions.NotFound)),
213 default_retry = retry.Retry()
219 # Overriding only the retry's deadline should also override the timeout's
221 result = wrapped_method(retry=default_retry.with_deadline(30))
235 default_retry = retry.Retry()
|
| /external/python/python-api-core/tests/asyncio/gapic/ |
| D | test_config_async.py | 72 retry, timeout = method_configs["AnnotateVideo"]
73 assert retry._predicate(exceptions.DeadlineExceeded(None))
74 assert retry._predicate(exceptions.ServiceUnavailable(None))
75 assert retry._initial == 1.0
76 assert retry._multiplier == 2.5
77 assert retry._maximum == 120.0
78 assert retry._deadline == 600.0
83 retry, timeout = method_configs["Other"]
84 assert retry._predicate(exceptions.FailedPrecondition(None))
85 assert retry._initial == 1.0
[all …]
|
| /external/curl/docs/cmdline-opts/ |
| D | retry-all-errors.d | 3 Long: retry-all-errors
4 Help: Retry all errors (use with --retry)
7 Example: --retry 5 --retry-all-errors $URL
8 See-also: retry
11 Retry on any error. This option is used together with --retry.
19 **WARNING**: For server compatibility curl attempts to retry failed flaky
31 --retry is used then curl will retry on some HTTP response codes that indicate
33 as 404. If you want to retry on all response codes that indicate HTTP errors
|
| D | retry-connrefused.d | 3 Long: retry-connrefused
4 Help: Retry on connection refused (use with --retry)
7 Example: --retry-connrefused --retry 7 $URL
8 See-also: retry retry-all-errors
12 error too for --retry. This option is used together with --retry.
|
| D | retry.d | 3 Long: retry
6 Help: Retry request if transient problems occur
8 Example: --retry 7 $URL
9 See-also: retry-max-time
13 will retry this number of times before giving up. Setting the number to 0
18 When curl is about to retry a transfer, it will first wait one second and then
21 using --retry-delay you disable this exponential backoff algorithm. See also
22 --retry-max-time to limit the total time allowed for retries.
24 Since curl 7.66.0, curl will comply with the Retry-After: response header if
25 one was present to know when to issue the next retry.
|
| /external/autotest/utils/frozen_chromite/lib/ |
| D | retry_util.py | 27 """Returns a retry handler for given exception(s).
40 """The strategy of the delay between each retry attempts.
61 """Sleep to delay the current retry."""
78 """Decorator to handle retry on exception.
91 checks whether the retry should be continued or not based on the given
95 If the |handler| returns True, retry will be continued. Otherwise no
96 further retry will be made, and an exception will be raised.
99 exception class(es) (or its subclass), continues to retry. Otherwise no
100 further retry will be made, and an exception will be raised.
101 - If neither is given, just continues to retry on any Exception instance.
[all …]
|
| /external/libwebsockets/include/libwebsockets/ |
| D | lws-retry.h | 40 * \param retry: the retry backoff table we are using, or NULL for default
46 * next connection retry, according to the backoff table \p retry. *\p conceal is
51 * If \p retry is NULL, a default of 3s + (0..300ms jitter) is used. If it's
56 lws_retry_get_delay_ms(struct lws_context *context, const lws_retry_bo_t *retry,
64 * \param retry: the retry backoff table we are using, or NULL for default
68 * Helper that combines interpreting the retry table with scheduling a sul to
74 lws_sorted_usec_list_t *sul, const lws_retry_bo_t *retry,
78 * lws_retry_sul_schedule_retry_wsi() - retry sul schedule helper using wsi
80 * \param wsi: the wsi to set the hrtimer sul on to the next retry interval
85 * Helper that uses context, tid and retry policy from a wsi to call
[all …]
|
| /external/volley/core/src/test/java/com/android/volley/toolbox/ |
| D | BasicNetworkTest.java | 169 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in socketTimeout()
175 // should retry socket timeouts in socketTimeout()
176 verify(mMockRetryPolicy).retry(any(TimeoutError.class)); in socketTimeout()
186 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in noConnectionDefault()
192 // should not retry when there is no connection in noConnectionDefault()
193 verify(mMockRetryPolicy, never()).retry(any(VolleyError.class)); in noConnectionDefault()
204 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in noConnectionRetry()
210 // should retry when there is no connection in noConnectionRetry()
211 verify(mMockRetryPolicy).retry(any(NoConnectionError.class)); in noConnectionRetry()
223 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in noConnectionNoRetry()
[all …]
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | suite.py | 62 """Maintain retry information.
64 @var _retry_map: A dictionary that stores retry history.
68 The retry state of a job.
72 We've made an attempt to schedule a retry job. The
75 in scheduling a retry is different from a retry job failure.
76 For each job, we only attempt to schedule a retry once.
78 its second retry job failed. When we attempt to create
79 a third retry job to retry the second, we hit an rpc
83 A retry job has already been successfully
89 @var _retry_level: A retry might be triggered only if the result
[all …]
|
| /external/autotest/server/cros/power/ |
| D | servo_charger.py | 17 from autotest_lib.client.common_lib.cros import retry
86 # retry loop in the autotest framework is to have a 'stable' library i.e.
99 for retry in range(_RETRYS):
102 return retry
104 if retry < _RETRYS - 1:
105 # Ensure this retry loop and logging isn't run on the
109 'recover.', role, retry + 1, str(e),
161 @retry.retry(error.TestError, timeout_min=_TIMEOUT_MIN,
164 """Check if servo role is as expected, if not, retry."""
172 @retry.retry(error.TestError, timeout_min=_TIMEOUT_MIN,
[all …]
|