o RDi_@snddlmZddlZddlZddlmZddlmZddlmZdZ dZ dZ Gd d d e Z Gd d d ZdS) ) annotationsN) stat_result)Path)sleepg?c@s eZdZdS) FileLockErrorN)__name__ __module__ __qualname__r r V/var/www/Datamplify/venv/lib/python3.10/site-packages/snowflake/connector/file_lock.pyrsrc@s&eZdZd ddZddZd d Zd S) FileLockpathrreturnNonecCs||_d|_tt|_dSNF)rlockedlogging getLoggerr logger)selfrr r r __init__szFileLock.__init__c Cspd}z|j}WntyYnty(}z td|jd|d}~ww|ra|jttkra|j dz|j WntyJYnty`}z td|jd|d}~wwt }t t D]C}|j d|d|d|d}z |jjd d d |_Wn#tyt|Yqgty}z td |jd|d}~ww|jstd t ddS)NzFailed to stat lock file z due to e=zRemoving stale file lockz!Failed to remove stale lock file z"Trying to acquire file lock after z seconds in attempt number .i)modeTzFailed to acquire lock file z#Failed to acquire file lock, after z attempts.)rstatFileNotFoundErrorOSErrorrst_ctimetimeSTALE_LOCK_AGE_SECONDSrdebugrmdirINITIAL_BACKOFF_SECONDSrange MAX_RETRIESmkdirrFileExistsErrorr)rstatinfoebackoff_secondsattemptr r r __enter__sZ      zFileLock.__enter__cCs,z|jWn tyYnwd|_dSr)rr#rr)rexc_typeexc_valexc_tbcr r r __exit__Cs   zFileLock.__exit__N)rrrr)r r r rr-r1r r r r rs  +r) __future__rrr osrpathlibrrr&r$r! Exceptionrrr r r r s