߲jPldZddlmZddlZddlmZddlmZmZm Z m Z e rddl m Z d dZ Gdd Zy) zX41a!GWBW!Q$X ZZXs  AAc<eZdZddZd dZd dZd dZd dZd dZy)CredentialPoolAdminMixinc|j5|jfd}| dddyt|}|j|||j |j g|cdddS#1swYyxYw)zHClear only the target's local error state, preserving sibling cooldowns.c"|jk(SNide credential_ids rz7CredentialPoolAdminMixin.reset_status..)>Nstatus_cleared_ids)_lock_findr_replace_entry_persistr)selfr"rcleareds ` r reset_statusz%CredentialPoolAdminMixin.reset_statusss ZZ JJ>?E}  +51G   w / MMgjj\M :   sA4;A44A=c ddlm}|j5|jDcgc]@}|js0|j s$|j s|js |jr|B}}|rl|Dchc]}|j}}|jDcgc]}|j|vr t|n|c}|_|jt|t|cdddScc}wcc}wcc}w#1swYyxYw)aClear exhaustion state on every entry. Returns how many were cleared. ``failure_reason`` lives in ``extra``, not a dataclass field, so it is stripped explicitly. The persist declares the cleared ids because the disk-recency merge reads a cleared ``last_status_at`` (None -> epoch 0) as a stale snapshot and would copy a still-binding cooldown back. rr r&N)rr r(_entries last_statuslast_status_atlast_error_coder rrrr+listlen)r,r r!stale stale_idss rreset_statusesz'CredentialPoolAdminMixin.reset_statuses s 8 ZZ ====A$4$48I8IQM]M]abararE+01aQTT1 1"]]!01tty/@(+aG!  i Au:   2!  s5C:AC+'C:/C0C:"C54-C:+C::Dc 2ddlm}|j5|dks|t|jkDr dddy|jj |dz }t |jDcgc]\}}t||c}}|_||j|jDcgc]}|jc}|jg|j|jk(rd|_ |cdddScc}}wcc}w#1swYyxYw)Nr)persist_pool_entriespriority) removed_ids) rr:r(r5r0pop enumeraterproviderto_dictr _current_id)r,indexr:removedpr!rs r remove_indexz%CredentialPoolAdminMixin.remove_index8s> ZZ qyEC $66  mm'' 2G@I$--@XY1WQ3YDM  .2mm.Nr$r%Nr<c|jSrr<)r!s rr#z5CredentialPoolAdminMixin.move_entry..Vs !**r%)keyc"|jk(Srrr s rr#z5CredentialPoolAdminMixin.move_entry..Xs (=r%)rrIr(r)r0rinsertmaxminintr5r@rrAsortedr+) r,r"r=rIrr!othersrFentriess ` r move_entryz#CredentialPoolAdminMixin.move_entryIsD ZZ ?JJ>?E} ? ?"&HA!$$-2GaHFH MM#aS]CK!@A5 I:CF:KL$!Qwq1-LGL &t}}g >"70DEDM MMO::=> ? ?IL ? ?s6DDDDAD$D;A D DD%cPt|xsdj}|sy|j5t|jdD]$\}}|j |k(s||dfccdddSt|jdDcgc]B\}}|j jj|jk(r||fD}}}t|dk(r|dd|dddfcdddSt|dkDrddd|dfcdddS|jr\t|}d|cxkrt|jkr!nn||j|dz dfcdddSddd|d fcdddSddd |d fcdddScc}}w#1swYyxYw) N)NNzNo credential target provided.r;)startrzAmbiguous credential label "z-". Use the numeric index or entry id instead.zNo credential #.zNo credential matching "z".) strstripr(r@r0rlabellowerr5isdigitrQ)r,targetrawidxr label_matchesrDs rresolve_targetz'CredentialPoolAdminMixin.resolve_targetZs&,B%%'? ZZ B' Q? , U88s?t++ B B , #,DMM"CC;;$$&,,.#))+=e M =!Q&$Q'*M!,rxs/B" 666Zqqr%