o ~j6h/ @sXddlZddlZddlZddlmmZeeZ GdddZ Gdddej Z dS)Nc@s8eZdZdZddZddZddZdd Zd d Zd S) RefreshThreadManagerzD Organizes exactly one background job that refresh a token. cCsd|_t|_dS)zInitializes the manager.N)_worker threadingLock_lockselfr j/var/www/html/chefvision.cloud.itp360.com/venv/lib/python3.10/site-packages/google/auth/_refresh_worker.py__init__szRefreshThreadManager.__init__cCs|dus|dur td|j>|jdur%|jjdur% WddS|jdus/|jsFt|t|d|_|j WddSWddS1sQwYdS)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 InvalidValuerr _error_infois_alive RefreshThreadcopydeepcopystart)rr r r r r start_refresh#s$    z"RefreshThreadManager.start_refreshcCsJ|j|jrd|j_WddSWddS1swYdS)zU Removes any errors that were stored from previous background refreshes. N)rrrrr r r clear_error>s  "z RefreshThreadManager.clear_errorcCs|j}d|d<|S)z2Pickle helper that serializes the _lock attribute.Nr)__dict__rrstater r r __getstate__Fs z!RefreshThreadManager.__getstate__cCst|d<|j|dS)z4Pickle helper that deserializes the _lock attribute.rN)rrrupdaterr r r __setstate__Ls z!RefreshThreadManager.__setstate__N) __name__ __module__ __qualname____doc__r rrrrr r r r rs rcs(eZdZdZfddZddZZS)rz, Thread that refreshes credentials. c s(tjdi|||_||_d|_dS)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)rr r kwargs __class__r r r Ws  zRefreshThread.__init__c CsRz |j|jWdSty(}ztd|||_WYd}~dSd}~ww)z1 Perform the credential refresh. z"Background refresh failed due to: N)r#refreshr$ Exception_LOGGERerrorr)rerrr r r runeszRefreshThread.run)rrr r!r r- __classcell__r r r&r rRs r) rloggingrgoogle.auth.exceptionsauth exceptionsr getLoggerrr*rThreadrr r r r s :