/usr/lib/rads/venv/lib/python3.13/site-packages/bakauth/__pycache__
Edit: /usr/lib/rads/venv/lib/python3.13/site-packages/bakauth/__pycache__/sess.cpython-313.pyc (5394B)
j S r SSKJrJr SSKrSSKrSSKJr SSKJ r SSK
r
Sr Sr \R " S5 R \R 5 " S S
\R 5 r " S S \R 5 r " S
S\5 r " S S\
R( 5 rSSS.S\S\S\S\S\S\\S4 S\S\\\4 4S jjrg) z8Handles automatic retries for Backup Authority API calls )UnionAnyN)Retry) HTTPAdapter zurllib3.connectionpoolc X \ rS rSrSrSrSrSrSrSr Sr
S r S
r S r
S rS
rSrSrSrSrSrSrg)Status z Backup Authority Error Codesr r
N)__name__
__module__ __qualname____firstlineno____doc__REQUEST_EXCEPTIONOKAYERROR ARGS_MISSINGUNHANDLED_EXCEPTIONSQLALCHEMY_ERRORAMP_DOWNWRONG_SERVER_CLASS AUTH_FAILEDINTERNAL_NO_QUOTAPRODUCTION_ONLYVDED_AMP_MISSINGLOOKUP_MISSING
AUTH_MIGRATED NO_REPLICANT INTERNAL_VPS__static_attributes__r ?/usr/lib/rads/venv/lib/python3.13/site-packages/bakauth/sess.pyr
r
s[ & D
ELHKONMLLr1 r
c $ \ rS rSrSrSrSrSrSrg)MdsState% z&Possible states for vznode MDS backupsr r
r r N) r r r r r r! WARNCRITr0 r r1 r2 r4 r4 % s 0 D D Dr1 r4 c < ^ \ rS rSrSr SU 4S jjrSrU =r$ ) LoggedRetry- zLogs on HTTP retriesc Z > Ub [ R " SX$5 [ TU ]
XX4XV5 $ )Nzbakauth::%s: %s)loggingdebugsuper increment)selfmethodurlresponseerror_pool _stacktrace __class__s r2 r? LoggedRetry.increment0 s3 MM+S 8w %
r1 r )NNNNNN)r r r r r r? r0
__classcell__rG s @r2 r9 r9 - s$
r1 r9 c 8 ^ \ rS rSrSrS\S\4U 4S jjrSrU =r $ )BakAuthSession@ z,Custom requests.Session for bakauth requestsretries log_retriesc > [ TU ] 5 U( a [ O[ nU R S[ U" UUUUS/SS9S95 g )Nhttps://i g ?)totalreadconnectstatusstatus_forcelistbackoff_factor) max_retries)r> __init__r9 r mountr )r@ rN rO retry_classrG s r2 rY BakAuthSession.__init__C sJ
%0ke
'! #"&)U#&
r1 r )
r r r r r intboolrY r0 rI rJ s @r2 rL rL @ s 6
$
r1 rL T)authrO bakauth_hosturidatatimeoutrN r_ rO returnc [ XF5 nUR SU SUR S5 3UUUS9nSSS5 WR 5 n [ U S 5 n XS 4$ ! , ( d f N4= f! [ R R
ai n U R R n
O0! [ a# [ R [ U 5 4s s Sn A $ f = f[ R U
SU 34s Sn A $ Sn A ff = f! [ a [ R SW 34s $ f = f! [ a [ R n Nf = f)
ar Performs a Backup Authority API request
Args:
bakauth_host (str): bakauth server fqdn
uri (str): endpoint uri to use
data (dict): POST form data
timeout (int): seconds before raising BakAuthDown
retries (int): number of automatic retries
auth (tuple | None): HTTP auth info
Returns:
(Status, data): Status response (enum) and returned data
rQ z:4002//)rB r_ rc rb Nz: z Invalid JSON from auth server: rU rb )rL postlstriprequests
exceptionsRequestExceptionrequestrB AttributeErrorr
r strjson
ValueErrorr" )
r` ra rb rc rN r_ rO sessionrawexcrB retrU s
r2 rg rg U s9 .
9
G
1W,, |nF3::c?2CD C 2Qhhj H
& v; + 2
1 / / 9 6++//C 6++SX5 5 6''C53% 88 9 Q''+J3%)PPPQ s A4 (A#A4 C> D# #
A1-A4 1A4 4 C;B*)C6*%CC6C;CC60C;6C;> D D #E ?E ) r typingr r r< enumurllib3.util.retryr requests.adaptersr ri DEFAULT_TIMEOUTDEFAULT_RETRIES getLoggersetLevelr" Enumr
r4 r9 SessionrL rn dictr] tupler^ rg r r1 r2
r s > $ ) * + 4 4W]] CTYY *
tyy
%
&
X%%
8 $ - -
- -
-
- t
- - 63;- r1