g/ ddlZddlZddlZddlmcmZejeZ GddZ GddejZ y)Nc.eZdZdZdZdZdZdZdZy)RefreshThreadManagerzD Organizes exactly one background job that refresh a token. cDd|_tj|_y)zInitializes the manager.N)_worker threadingLock_lockselfs P/var/www/openai/venv/lib/python3.12/site-packages/google/auth/_refresh_worker.py__init__zRefreshThreadManager.__init__s ^^% c||tjd|j5|j |jj dddy|j|jj s?t |tj||_|jjdddy#1swYyxYw)auStarts a refresh thread for the given credentials. The credentials are refreshed using the request parameter. request and cred MUST not be None Returns True if a background refresh was kicked off. False otherwise. Args: cred: A credentials object. request: A request object. Returns: bool NzQUnable to start refresh. cred and request must be valid and instantiated objects.F)credrequestT) e InvalidValuer r _error_infois_alive RefreshThreadcopydeepcopystart)r rrs r start_refreshz"RefreshThreadManager.start_refresh#s <7?..c ZZ||'DLL,D,D,PZ||#4<<+@+@+B,$ g@VW  ""$ s$CA%CC c|j5|jrd|j_dddy#1swYyxYw)zU Removes any errors that were stored from previous background refreshes. N)r rrr s r clear_errorz RefreshThreadManager.clear_error>s(ZZ||+/ (ZZs4=cD|jj}d|d<|S)z2Pickle helper that serializes the _lock attribute.Nr )__dict__rr states r __getstate__z!RefreshThreadManager.__getstate__Fs" ""$g rchtj|d<|jj|y)z4Pickle helper that deserializes the _lock attribute.r N)rrrupdaters r __setstate__z!RefreshThreadManager.__setstate__Ls$")g U#rN) __name__ __module__ __qualname____doc__r rrr!r$rr rrs & 60 $rrc(eZdZdZfdZdZxZS)rz, Thread that refreshes credentials. c Nt|di|||_||_d|_y)zInitializes the thread. Args: cred: A Credential object to refresh. request: A Request object used to perform a credential refresh. **kwargs: Additional keyword arguments. Nr))superr _cred_requestr)r rrkwargs __class__s r r zRefreshThread.__init__Ws+ "6"  rc |jj|jy#t$r)}tj d|||_Yd}~yd}~wwxYw)z1 Perform the credential refresh. z"Background refresh failed due to: N)r-refreshr. Exception_LOGGERerrorr)r errs r runzRefreshThread.runesL # JJ  t}} - # MM>seD E"D   #s%( AAA)r%r&r'r(r r7 __classcell__)r0s@r rrRs  #rr) rloggingrgoogle.auth.exceptionsauth exceptionsr getLoggerr%r4rThreadrr)rr r?sE "" '  H %7$7$t#I$$#r