eQj ddlZddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZedZej$ejfdedeegefdegefd eegdfd egefd ef d Zeej$ejfdegefded eegdfd egefd ef d Zej$ejfdedeegefdegefd eegdfd egefd ef dZy)N)CallableTypeVar) BackoffDEFAULT_BACKOFF DEFAULT_RETRYDEFAULT_RETRY_AFTER_BACKOFF_delay is_conflictis_retry_after_responseis_too_many_requestsretry_after_backoffretry_after_max_retriesretry_after_secondsTbackoff retriablefn sleep_func random_funcreturnc|j}|j}d}|dkDr |S|#t$r:}||s|}|dk(rYd}~|t||||\} }}|| Yd}~nd}~wwxYw|dkDrVO)zRun ``fn`` and retry while ``retriable`` returns True. This is a 1:1 implementation of ``k8s.io/client-go/util/retry.OnError``. Nrr)stepsduration Exceptionr ) rrrrrrr last_errorerrordelays [/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/utils/retry.pyon_errorr )s MMEHJ !) 4K  U#Jz  &,x+&7 "E8U u    !)s* A-A( A((A-c(t|t|||S)aRun ``fn`` and retry on HTTP 409 Conflict responses. This is a 1:1 implementation of ``k8s.io/client-go/util/retry.RetryOnConflict``. Callers should re-read the object inside ``fn`` before each write attempt, so every retry uses the latest resource version. )r r )rrrrs rretry_on_conflictr"Ks G["j+ FFc|j}|j}d}|dkDr |S|#t$rN}||s|}|dk(rYd}~|t||||\} }}t |} | | | kDr| } || Yd}~nd}~wwxYw|dkDrjc)a0Run ``fn`` with client-go REST Retry-After sleep semantics. This is a 1:1 implementation of the wait selection in ``k8s.io/client-go/rest.WithRetry``: if the retriable response carries a valid ``Retry-After`` header, that delay is used; otherwise the supplied backoff delay is used. Nrr)rrrr r) rrrrrrrrrr retry_afters ron_retry_after_errorr&\s MMEHJ !) 4K  U#Jz &,x+&7 "E8U-e4K&;+># u    !)s* BA< .A<<B)randomtimetypingrr _retry_baserrrr r r r r rrrrsleeprboolfloatr r"r&r#rr/s $     CL+/**'-}}   T)* Q%$'  "e)$   H%*.**'-}} GQG G%$'G"e)$ G  G*+/**'-}} $ $ T)*$ Q$%$' $ "e)$ $  $r#