RetryPolicy

RetryPolicyclassdataclass#

Re-exported from ocx_sdk._typesView source

class RetryPolicy(attempts: int = 3, backoff: float = 1.0, multiplier: float = 2.0, max_backoff: float = 30.0, max_retry_after: float = 300.0, jitter: bool = True, retry_on: frozenset[ExitCode] = frozenset({ExitCode.TEMP_FAIL}), sleep: Callable[[float], None] | None = None)

How to retry a failure ocx classified as transient.

Attempt one is not a retry: attempts=3 means at most two backoff waits. timeout is per attempt, so the worst case is attempts * timeout + sum(backoff).

Attributes

Name	Type	Description
attempts	int	Total attempts, including the first.
backoff	float	Delay before the first retry, in seconds.
multiplier	float	Growth factor applied to backoff per retry.
max_backoff	float	Ceiling for the computed delay.
max_retry_after	float	Ceiling for a server-supplied Retry-After. It is honored verbatim up to this value rather than truncated to max_backoff — truncating it would hammer a registry that just asked for room. Beyond it the answer is to fail, not to wait.
jitter	bool	Draw the delay uniformly from [0, delay] (AWS full jitter).
retry_on	frozenset[ExitCode]	Exit codes worth retrying. Applies to the process path only; _dist classifies by transport condition instead, so this set does not affect bootstrap.ensure().
sleep	Callable[[float], None] | None	Sleep seam, defaulting to time.sleep. Async drivers use asyncio.sleep and ignore this field.

attemptsattributeclass attributeinstance attribute#

View source

attempts: int = 3

backoffattributeclass attributeinstance attribute#

View source

backoff: float = 1.0

jitterattributeclass attributeinstance attribute#

View source

jitter: bool = True

max_backoffattributeclass attributeinstance attribute#

View source

max_backoff: float = 30.0

max_retry_afterattributeclass attributeinstance attribute#

View source

max_retry_after: float = 300.0

multiplierattributeclass attributeinstance attribute#

View source

multiplier: float = 2.0

retry_onattributeclass attributeinstance attribute#

View source

retry_on: frozenset[ExitCode] = frozenset({ExitCode.TEMP_FAIL})

sleepattributeclass attributeinstance attribute#

View source

sleep: Callable[[float], None] | None = None