swh.storage.proxies.retry module#

swh.storage.proxies.retry.should_retry(retry_state: RetryCallState) → bool[source]#

Retry if the error/exception is (probably) not about a caller error

class swh.storage.proxies.retry.wait_transient_exceptions(wait: float)[source]#

Bases: wait_base

Wait longer when servers return HTTP 503.

class swh.storage.proxies.retry.stop_after_attempt_transient_exceptions(max_attempts: int)[source]#

Bases: stop_base

Retry twice the number of max attempts when servers return HTTP 503.

swh.storage.proxies.retry.retry_function(storage, attribute_name)[source]#
class swh.storage.proxies.retry.RetryingProxyStorage(storage: Dict[str, Any])[source]#

Bases: object

Storage implementation which retries adding objects when it specifically fails (hash collision, integrity error).