E0j-ddlZddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZejd ZeejejZeee d Zd Zd ZeeZ eed Z!dZ"ej#e"de$de$de$de$fdZ%de$de$fdZ&GddeZ'GddeZ(Gdde eZ)GddZ*Gdd e*Z+Gd!d"e*Z,Gd#d$e eZ-dS)%N)datetime)Enum)CallableGenericTypeVar CoroutineAny) Semaphore)ThreadPoolExecutor)CredentialException) ICredentials credentialsTldznon-blocking-refresh) max_workersthread_name_prefixc<tddS)NF)wait)EXECUTORshutdownu/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/alibabacloud_credentials/provider/refreshable.py_shutdown_handlerrs 5!!!!!rnow jitter_start jitter_endreturnc6tj||}||zSN)randomrandint)rrr jitter_amounts r _jitter_timer$#sN<<.run_asyncio_loopsM)++D  "4 ( ( (  # #FFHH - - - JJLLLLLr)re)r8r`r~s ` rrgzNonBlocking.prefetch_asyncs;      &'''''rNrhrrrrjrjssJ 0x 0 0 0 0(8((((((rrjc&eZdZdefdZdefdZdS)OneCallerBlocksr`c|dSr rrds rrezOneCallerBlocks.prefetchsrc*K|d{VdSr rrds rrgzOneCallerBlocks.prefetch_asyncs!fhhrNrhrrrrrsJx8rrc $eZdZdZdZejefdege e fdege e e e e ffdede fdZde fd Zde fd Zdefd Zdefd Zd ZdZdZdZde e de e fdZdede e fdZdS)RefreshCachedSupplierirefresh_callablerefresh_callable_asyncstale_value_behaviorprefetch_strategyc||_||_||_||_d|_d|_t j|_dS)Nr) _refresh_callable_refresh_callable_async_stale_value_behavior_prefetch_strategy_consecutive_refresh_failures _cached_value threadingLock _refresh_lock)r8rrrrs rr9zRefreshCachedSupplier.__init__sJ "2'=$%9""3-.*!&^--rrcb|r/td|nT|r@td|jjj||j SNzRefreshing synchronouslyzPrefetching using strategy: ) _cache_is_stalerodebug_refresh_cache_should_initiate_cache_prefetchr __class__rG_prefetch_cacherrUr;s r _sync_callz RefreshCachedSupplier._sync_calls    ! ! # II0 1 1 1    ! ! ! !  1 1 3 3 # IIaT5L5V5_aa b b b  " " "!'')))rc~K|r5td|d{VnZ|rFtd|jjj|d{V|j Sr) rror_refresh_cache_asyncrrrrG_prefetch_cache_asyncrrUr;s r _async_callz!RefreshCachedSupplier._async_calls    ! ! / II0 1 1 1++-- - - - - - - - -  1 1 3 3 / IIaT5L5V5_aa b b b,,.. . . . . . . .!'')))rc|jdSttjtj|jkSNT)rrKtimemktime localtimerSr;s rrz%RefreshCachedSupplier._cache_is_stalesD   %44;t~//0011T5G5R5R5T5TTTrc|jdSttjtj|jkSr)rrKrrrrTr;s rrz5RefreshCachedSupplier._should_initiate_cache_prefetchsD   %44;t~//0011T5G5U5U5W5WWWrcD|j|jdSr )rrerr;s rrz%RefreshCachedSupplier._prefetch_caches" (()<=====rc|jtj} |s|r_ |||_n1#t$r$}| ||_Yd}~nd}~wwxYw|r|j dSdS#|r|j wwxYwN)timeout) rrnrREFRESH_BLOCKING_MAX_WAITrr_handle_fetched_successrrrs_handle_fetched_failurertr8acquiredexs rrz$RefreshCachedSupplier._refresh_caches%--6K6e-ff -##%% J)M)M)O)O JJ)-)E)EdF\F\F^F^)_)_D&& JJJ)-)E)Eb)I)ID&&&&&&J -"**,,,,, - -x -"**,,,, -s5(C ,A=<C = B+B&!C &B++C C+cTK|j|jd{VdSr )rrgrr;s rrz+RefreshCachedSupplier._prefetch_cache_asyncs8%44T5NOOOOOOOOOOOrcK|jtj} |s|re ||d{V|_n1#t$r$}| ||_Yd}~nd}~wwxYw|r|j dSdS#|r|j wwxYwr) rrnrrrrrrrrsrrtrs rrz*RefreshCachedSupplier._refresh_cache_asyncs-%--6K6e-ff -##%% J)M)M)O)O JJ)-)E)EDLhLhLjLjFjFjFjFjFjFj)k)kD&& JJJ)-)E)Eb)I)ID&&&&&&J -"**,,,,, - -x -"**,,,, -s5(C2BC B3B.)C.B33CC3rUc td|d|jd|_t t jt j}||krjtdtj |dtj ||S||tj zkrt dtj |dtj |t|||St d tj |tj zd |jt#d ||jkryt d tj |jdtj |j|jS|jt&jkrt d tj |jdtj |dzt|j|dz|jS|t dt+jddzdz z}t dtj |dtj |jt|j||jS)Nz5Refresh credentials successfully, retrieved value is z, cached value is rzRetrieved value stale time is z. Using staleTime of z+Retrieved value stale time is in the past (z). Using staleTime of rUrSrTzBRetrieved value expiration time of the credential is in the past (z). Trying use the cached value.zNo cached value was found.zCached value staleTime is z(Cached value expiration is in the past (z). Using expiration of r'iPi!N-Cached value expiration has been extended to z= because the downstream service returned a time in the past: )rorrrrKrrrrSr fromtimestampr STALE_TIMErprRrUrTr rrMrOr!r")r8rUrextended_stale_times rrz-RefreshCachedSupplier._handle_fetched_successs w%wwcgcuwwxxx-.*$+dn..//00 !!## # # II_1GHXHXHZHZ1[1[__rzsIJOJZJZJ\J\s]s]__ ` ` `L !!##&;&FF F F KK^h>TUZUeUeUgUg>h>h^^AIAWX[A\A\^^ _ _ _ u{{}}TYTgTgTiTijjj j  @QYQghmhxhxhzhz~S~^i^R_R_ @ @ @ A A A   %%&BCC C 4%0022 2 2 KKuX-CDDVDaDaDcDc-d-duu|D|RSWSeSpSpSrSr|s|suu v v v% %  '+=+D D D KKm8;QRVRdRoRoRqRq;r;rmmLTLbcfijcjLkLkmm n n n t'9'?'?'A'AcTUg/3/A/O/O/Q/QSSS S#&Y=9Y9Y-Y]a,a(b(b"b  KKd@VWj@k@kddkskABFBTB_B_BaBakbkbdd e e e t'9'?'?'A'ANa/3/A/O/O/Q/QSSS Sr exceptionc td|jd||jst||t t jt j}||jkr|jS|xj dz c_ |j tj krt||t t|dzdt|j dz }tdtj|d|j dt#|j||jS) Nz,Refresh credentials failed, cached value is z , error: r'rrzF because calling the downstream service failed (consecutive failures: z).r)rorprrrKrrrrSrrrMrOr$r*rrrRrUrT)r8rrnew_stale_times rrz-RefreshCachedSupplier._handle_fetched_failures k4CUkk`ikklll!  MM) $ $ $O$+dn..//00 #..00 0 0% % **a/**  %);)B B B MM) $ $ $O S4Z/HIk/l/lmmpttvvN KKU@VWe@f@fUUosoQUUU V V V t'9'?'?'A'An/3/A/O/O/Q/QSSS SrN)rGrHrIrrrMrOrrrRrrr r_r9rrboolrrrrrrrrsrrrrrrsJ !=O>> - - -PPP - - -"S]1-="S-PQBR"S"S"S"SHSS}Q?OSSSSSSrr).r!rxrloggingratexitrenumrtypingrrrrr r concurrent.futures.threadr #alibabacloud_credentials.exceptionsr alibabacloud_credentials_apir getLoggerrosetLevelINFO StreamHandlerch addHandlerrr]MAX_CONCURRENT_REFRESHESrmrrregisterrKr$r*r,rMrRr_rjrrrrrrs  ==============888888CCCCCC555555g && W\Wr GCLL  %I&>??  )H^ _ _ _"""!"""c## CC #####,###:        #####GAJ###&""""""""((((("(((4&BSBSBSBSBSGAJBSBSBSBSBSr