§ ظىNgEم َ<—ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlmZm Z mZeje¦«ZdZdZdZejjejjzZddgZe jeejfZdd œd e jde jde jfd „Zej ddede!de j"e j#fd„¦«Z$Gd„dej%¦«Z&Gd„de&¦«Z'Gd„de'¦«Z(Gd„de'¦«Z)Gd„de&¦«Z*Gd„de*¦«Z+dS)éNé)ع constantsع exceptionsعportalockerégذ?FعLockعopen_atomic)ع test_valueعargsr عreturncَ<‡—tˆfd„|D¦«d¦«S)aژSimple coalescing function that returns the first value that is not equal to the `test_value`. Or `None` if no value is valid. Usually this means that the last given value is the default value. Note that the `test_value` is compared using an identity check (i.e. `value is not test_value`) so changing the `test_value` won't work for all values. >>> coalesce(None, 1) 1 >>> coalesce() >>> coalesce(0, False, True) 0 >>> coalesce(0, False, True, test_value=0) False # This won't work because of the `is not test_value` type testing: >>> coalesce([], dict(spam='eggs'), test_value=[]) [] c3َ$•K—|] }|‰u¯|V—ŒdS©N©)ع.0عargr s €ْM/var/www/html/ai-engine/env/lib/python3.11/site-packages/portalocker/utils.pyْ zcoalesce..4s-ّèè€ذ>ذ>ک¨°:ذ(=ذ(=گذ(=ذ(=ذ(=ذ(=ذ>ذ>َN)عnext)r rs` rعcoalescers*ّ€ُ,ذ>ذ>ذ>ذ> ذ>ر>ش>ہرEشEذErTعfilenameعbinaryc#َK—tj|¦«}| ¦«r J|›d‌¦«‚|j dd¬¦«tj|rdpdt|j¦«d¬¦«}|V—| ¦«tj | ¦«¦«| ¦« tj |j|¦«tjt"¦«5tj|j¦«ddd¦«dS#1swxYwYdS#tjt"¦«5tj|j¦«ddd¦«w#1swxYwYwxYw) a6Open a file for atomic writing. Instead of locking this method allows you to write the entire file and move it to the actual location. Note that this makes the assumption that a rename is atomic on your platform which is generally the case but not a guarantee. http://docs.python.org/library/os.html#os.rename >>> filename = 'test_file.txt' >>> if os.path.exists(filename): ... os.remove(filename) >>> with open_atomic(filename) as fh: ... written = fh.write(b'test') >>> assert os.path.exists(filename) >>> os.remove(filename) >>> import pathlib >>> path_filename = pathlib.Path('test_file.txt') >>> with open_atomic(path_filename) as fh: ... written = fh.write(b'test') >>> assert path_filename.exists() >>> path_filename.unlink() z existsT)عparentsعexist_okعwbعwF)عmodeعdirعdeleteN)عpathlibعPathعexistsعparentعmkdirعtempfileعNamedTemporaryFileعstrعflushعosعfsyncعfilenoعcloseعrenameعnameع contextlibعsuppressع Exceptionعremove)rrعpathعtemp_fhs rr r 7sëèè€ُ<!œ hر/ش/€Dàڈ{ٹ{‰}Œ}ذ0ذ0 ذ0ذ0ذ0ر0ش0ذ0ً „K×زکd¨Tذر2ش2ذ2هش)ط ˆ_کذ # فگ”رشطًٌô€Gً €M€M€Mط‡M‚MپO„O€Oف„HˆWڈ^ٹ^ر ش رشذط‡M‚MپO„O€Oً$ف Œ گ'”, ر%ش%ذ%ه ش ¥ر +ش +ً $ً $فŒIگg”lر#ش#ذ#ً $ً $ً $ٌ $ô $ً $ً $ً $ً $ً $ً $ً $ًّّّ $ً $ً $ً $ً $ً $ّچZش ¥ر +ش +ً $ً $فŒIگg”lر#ش#ذ#ً $ً $ً $ٌ $ô $ً $ً $ً $ً $ً $ً $ًّّّ $ً $ً $ً $ً $ّّّsBأD;ؤD.ؤ.D2ؤ5D2ؤ;FإE;إ/Fإ;E?إ?FئE?ئFcَJ—eZdZUeed<eed<eed< ddejedejedejefd„Ze j ddejedejedejedejejfd„¦«Z dejedejedejefd„Ze j d „¦«Zdejejfd „Zdejejedejed ejdejefd„Zd„ZdS)عLockBaseعtimeoutعcheck_intervalعfail_when_lockedNcَ¢—t|t¦«|_t|t¦«|_t|t ¦«|_dSr)rعDEFAULT_TIMEOUTr9عDEFAULT_CHECK_INTERVALr:عDEFAULT_FAIL_WHEN_LOCKEDr;©عselfr9r:r;s rع__init__zLockBase.__init__tsF€ُ ر9ش9ˆŒف& ~ص7MرNشNˆشف (طف$ٌ! ô! ˆشذذrrcَ—dSrrr@s rعacquirezLockBase.acquireپs €ً$' 3rc#َژK—t||jd¦«}t||jd¦«}dV—d}tj¦«}||ztj¦«krc|dz }|V—tj¦«|z }tjt d||z|z ¦«¦«||ztj¦«k°adSdS)Ngrrgü©ٌزMbP?)rr9r:عtimeعperf_counterعsleepعmax)rAr9r:ع f_timeoutعf_check_intervalعiع start_timeعsince_start_times rع_timeout_generatorzLockBase._timeout_generator‰sعèè€ُ کW d¤l°Cر8ش8ˆ ف# N°Dش4GبرMشMذàˆˆˆط ˆهش&ر(ش(ˆ طک9ر$¥tش'8ر':ش':ز:ذ:ط گ‰FˆAطˆGˆGˆGُ $ش0ر2ش2°Zر?ذفŒJ•sک5 1ذ'7ر#7ذ;Kر"KرLشLرMشMذMً ک9ر$¥tش'8ر':ش':ز:ذ:ذ:ذ:ذ:ذ:rcَ—dSrr©rAs rعreleasezLockBase.release‌s€طگsrcَ*—| ¦«Sr©rDrQs rع __enter__zLockBase.__enter__ َ€طڈ|ٹ|‰~Œ~ذrعexc_typeع exc_valueع tracebackcَ.—| ¦«dSr©rR)rArWrXrYs rع__exit__zLockBase.__exit__£s€ً ڈٹ‰Œˆطˆtrcَ.—| ¦«dSrr[)rAعinstances rع __delete__zLockBase.__delete__¬s€ط×زرشذذذr©NNN)ع__name__ع __module__ع__qualname__عfloatع__annotations__عboolعtypingعOptionalrBعabcعabstractmethodعIOعAnyStrrDعIteratorعintrOrRrUعTypeع BaseExceptionعAnyr\r_rrrr8r8lsô€€€€€€à €N€NپNàذذرàذذرً+/ط15ط26ً ً à” ش'ً ًœ¨ش.ً ً!œ/¨$ش/ً ً ً ً ً شً+/ط15ط26ً 'ً'à” ش'ً'ًœ¨ش.ً'ً!œ/¨$ش/ً 'ً Œگ6”=ش !ً'ً'ً'ٌشً'ًNà” ش'ًNًœ¨ش.ًNً Œکش ً NًNًNًNً( شطذٌشطًک6œ9 V¤]ش3ًًًًًà”/ &¤+¨mش"<ش=ًً”? =ش1ًً”:ً ً Œکش ًًًًًًًًًrr8c َp—eZdZdZddeeefdedede j ededed e jfd „Z dde j ede j ede j ede je jfd„Zde je jfd „Zd„Zde jfd„Zde jde jfd„Zde jde jfd„ZdS)rasLock manager with built-in timeout Args: filename: filename mode: the open mode, 'a' or 'ab' should be used for writing. When mode contains `w` the file will be truncated to 0 bytes. timeout: timeout when trying to acquire a lock check_interval: check interval while waiting fail_when_locked: after the initial lock failed, return an error or lock the file. This does not wait for the timeout. **file_open_kwargs: The kwargs for the `open(...)` call fail_when_locked is useful when multiple threads/processes can race when creating a file. If set to true than the system will wait till the lock was acquired and then return an AlreadyLocked exception. Note that the file is opened first and locked later. So using 'w' as mode will result in truncate _BEFORE_ the lock is checked. عaNrrr9r:r;عflagscَD—d|vrd}| dd¦«}nd}|€t}n*|tjjzstjdd¬¦«d|_t|¦«|_ ||_ ||_||_||_ ||_||_||_dS)NrTrsFْ&timeout has no effect in blocking moder©ع stacklevel)عreplacer=rع LockFlagsعNON_BLOCKINGعwarningsعwarnعfhr)rrعtruncater9r:r;rtعfile_open_kwargs) rArrr9r:r;rtr€rs rrBz Lock.__init__إs؛€ًگ$ˆ;ˆ;طˆHط—<’< Sر)ش)ˆDˆDàˆHàˆ?ف%ˆGˆGط‌)ش-ش:ر:ً فŒMط8طً ٌ ô ً ً /3ˆŒف ™]œ]ˆŒ طˆŒ ط&ˆŒ ط%ˆŒط%3ˆشط&6ˆشط*/ˆŒ ط 0ˆشذذrrcَn‡—t||j¦«}|jtjjzs|پt jdd¬¦«|jٹ‰r‰S| ¦«ٹˆfd„}d}| ||¦«D]†}d} | ‰¦«ٹnk#tj $r-}|}|r|¦«tj|¦«|‚Yd}~ŒSd}~wt$r$}|¦«tj |¦«|‚d}~wwxYw|r|¦«|‚| ‰¦«ٹ‰|_‰S)zAcquire the locked filehandleNrvrrwcَœ•—‰پHtjt¦«5‰ ¦«ddd¦«dS#1swxYwYdSdSr)r1r2r3r.)r~s€rع try_closezLock.acquire..try_closes‘ّ€àˆ~فش(ر3ش3ًًط—H’H‘J”JگJًًًٌôًًًًًًًًًًًًًًّّّˆ~s‌?؟AءA)rr;rtrrzr{r|r}r~ع_get_fhrOع _get_lockrع LockExceptionع AlreadyLockedr3ع_prepare_fh) rAr9r:r;rƒع exceptionع_عexcr~s @rrDzLock.acquireçs؟ّ€ُ$ذ$4°dش6KرLشLذً”‌iش1ش>ر>ً àذ#هŒMط8طً ٌ ô ً ً*.¬ˆط ً طˆIًڈ\ٹ\‰^Œ^ˆً ً ً ً ً ًˆ à×(ز(¨°.رAشAً =ً =ˆAطˆIً =à—^’^ Bر'ش'گطگّفش+ً Gً Gً Gً گ ً$ًGطگI‘K”KگKف$ش2°9ر=ش=ہ3ذFًGًGًGًGًGًُّّّّ =ً =ً =ًگ ‘”گف ش.¨sر3ش3¸ذ<ًّّّّ =ًًّّّ طˆI‰KŒKˆKàˆOً× ز کbر !ش !ˆàˆŒطˆ s$آ B آ Dآ/#Cأ Dأ$DؤDcَ*—| ¦«SrrTrQs rrUzLock.__enter__-rVrcَٹ—|jr;tj|j¦«|j ¦«d|_dSdS)z)Releases the currently locked file handleN)r~rعunlockr.rQs rrRzLock.release0sC€àŒ7ً فشکtœwر'ش'ذ'طŒGڈMٹM‰OŒOˆOطˆDŒGˆGˆGً ً rcَ<—t|j|jfi|j¤ژS)zGet a new filehandle)عopenrrr€rQs rr„zLock._get_fh7s0€هطŒMطŒIً ً ًش#ً ً ً rr~cَ:—tj||j¦«|S)zT Try to lock the given filehandle returns LockException if it fails)rعlockrt©rAr~s rr…zLock._get_lock?s€ُ شککTœZر(ش(ذ(طˆ rcَh—|jr*| d¦«| d¦«|S)zڈ Prepare the filehandle for usage If truncate is a number, the file will be truncated to that amount of bytes r)rعseekr“s rrˆzLock._prepare_fhGs1€ًŒ=ً طڈGٹGگA‰JŒJˆJطڈKٹKک‰NŒNˆNàˆ rr`)rarbrcع__doc__r>r?عLOCK_METHODعFilenamer)rgrhrdrfrrzrBrkrlrDrUrRr„r…rˆrrrrr°s›€€€€€ًًً.ط*.ط 6ط!9ط%0ً 1ً 1àً 1ًً 1ً” ش'ً 1ً ً 1ًً 1ًش"ً 1ً 1ً 1ً 1ًH+/ط15ط26ً DًDà” ش'ًDًœ¨ش.ًDً!œ/¨$ش/ً Dً Œگ6”=ش !ًDًDًDًDًLک6œ9 V¤]ش3ًًًًًًًً کœً ً ً ً ًکFœIً¨&¬)ًًًًًکfœiً¨F¬Iًًًًًًrc َ¨‡—eZdZdZdeedefˆfd„ Z ddej e dej e dej ed ejfˆfd „ Z ˆfd„ZˆxZS) عRLockzï A reentrant lock, functions in a similar way to threading.RLock in that it can be acquired multiple times. When the corresponding number of release() calls are made the lock will finally release the underlying file lock. rsFcَb•—t¦« ||||||¦«d|_dS)Nr)عsuperrBع_acquire_count)rArrr9r:r;rtع __class__s €rrBzRLock.__init__\sCّ€ُ ‰Œ×زططططططٌ ô ً ً ˆشذذrNr9r:r;rcَœ•—|jdkr|j}n#t¦« |||¦«}|xjdz c_|sJ‚|S)Nr)r‌r~rœrD)rAr9r:r;r~r‍s €rrDz RLock.acquireosXّ€ًش !ز#ذ#ط”ˆBˆBه‘”—’ ¨.ذ:JرKشKˆBطذشکqر ذشطˆ ˆ ˆ طˆ rcَ¼•—|jdkrtjd¦«‚|jdkr t¦« ¦«|xjdzc_dS)Nrz'Cannot release more times than acquiredr)r‌rr†rœrR)rAr‍s €rrRz RLock.release}sgّ€طش !ز#ذ#فش*ط9ٌôً ًش !ز#ذ#ف‰GŒGڈOٹOرشذطذشکqر ذشذذrr`)rarbrcr–r=r>r—rBrgrhrdrfrkrDrRع __classcell__©r‍s@rrڑrڑUsـّ€€€€€ًًًطط-ططً ً ً ً ً ً ً*+/ط15ط26ً ًà” ش'ًًœ¨ش.ًً!œ/¨$ش/ً ً Œًًًًًًً!ً!ً!ً!ً!ً!ً!ً!ً!rrڑcَ&—eZdZdeedefd„Zd„ZdS)عTemporaryFileLockz.lockTc َz—t ||d||||¬¦«tj|j¦«dS)Nr)rrr9r:r;rt)rrBعatexitعregisterrR)rArr9r:r;rts rrBzTemporaryFileLock.__init__‰sN€ُ ڈ ٹ ططططط)ط-طً ٌ ô ً ُ Œکœر%ش%ذ%ذ%ذ%rcَ¸—t |¦«tj |j¦«rtj|j¦«dSdSr)rrRr+r5عisfilerعunlinkrQs rrRzTemporaryFileLock.releaseœsN€فڈٹگTرشذف Œ7ڈ>ٹ>ک$œ-ر(ش(ً %فŒIگd”mر$ش$ذ$ذ$ذ$ً %ً %rN)rarbrcr=r>r—rBrRrrrr¤r¤ˆsH€€€€€ًطط-ططً &ً&ً&ً&ً&%ً%ً%ً%ً%rr¤cَق‡—eZdZUdZejeed<ddej ¦«e edfdede de d e d ejedejedejefˆfd „ Zdejejfd„Zdejejfd„Zdejfd„Z dd ejedejedejedejefd„Zdejedefd„Zd„ZˆxZS)عBoundedSemaphorea0 Bounded semaphore to prevent too many parallel processes from running This method is deprecated because multiple processes that are completely unrelated could end up using the same semaphore. To prevent this, use `NamedBoundedSemaphore` instead. The `NamedBoundedSemaphore` is a drop-in replacement for this class. >>> semaphore = BoundedSemaphore(2, directory='') >>> str(semaphore.get_filenames()[0]) 'bounded_semaphore.00.lock' >>> str(sorted(semaphore.get_random_filenames())[1]) 'bounded_semaphore.01.lock' r’عbounded_semaphoreْ{name}.{number:02d}.lockTعmaximumr0عfilename_patternع directoryr9r:r;cَâ•—||_||_||_||_d|_t¦« |||¬¦«|r|dkrtjdtd¬¦«dSdS)N)r9r:r;rz_`BoundedSemaphore` without an explicit `name` argument is deprecated, use NamedBoundedSemaphorerrw) r¯r0r°r±r’rœrBr|r}عDeprecationWarning© rAr¯r0r°r±r9r:r;r‍s €rrBzBoundedSemaphore.__init__´sںّ€ًˆŒطˆŒ ط 0ˆشط"ˆŒط+/ˆŒ ف ‰Œ×زطط)ط-ً ٌ ô ً ًً گtذ2ز2ذ2فŒMًDه"طً ٌ ô ً ً ً ً3ذ2rrcَD‡—ˆfd„t‰j¦«D¦«S)Ncَ:•—g|]}‰ |¦«‘ŒSr)عget_filename)rعnrAs €rْ z2BoundedSemaphore.get_filenames..زs'ّ€ذBذBذB¨گ×!ز! !ر$ش$ذBذBذBr)عranger¯rQs`rع get_filenameszBoundedSemaphore.get_filenamesرs'ّ€طBذBذBذBe°D´Lر.Aش.AذBرBشBذBrcَp—t| ¦«¦«}tj|¦«|Sr)عlistr»عrandomعshuffle)rAع filenamess rعget_random_filenamesz%BoundedSemaphore.get_random_filenamesشs1€فک×+ز+ر-ش-ر.ش.ˆ فŒگyر!ش!ذ!طذrcَx—tj|j¦«|j |j|¬¦«zS)N)r0عnumber)r"r#r±r°عformatr0)rArأs rr·zBoundedSemaphore.get_filenameظs>€فŒ|کDœNر+ش+¨dش.C×.Jز.Jط”طً/Kٌ/ ô/ ٌ ً rNcَJ—|jr Jd¦«‚| ¦«}| ||¦«D]<}t d||¦«| |¦«r |jcSŒ=t ||j¦«x}rtj ¦«‚dS)NzAlready lockedztrying lock (attempt %d) %r) r’r»rOعloggerعdebugعtry_lockrr;rr‡)rAr9r:r;rہr¸s rrDzBoundedSemaphore.acquireكsؤ€ً”9ذ.ذ.ذ.ر.ش.ذ.à×&ز&ر(ش(ˆ à×(ز(¨°.رAشAً !ً !ˆAفڈLٹLذ6¸¸9رEشEذEàڈ}ٹ}کYر'ش'ً !ط”yذ ذ ذ ً !ُ (ططش!ٌ ô ً ذً -ُش*ر,ش,ذ,àˆtrrہcَ—|D]†}t d|¦«t|d¬¦«|_ |j ¦«t d|¦«dS#t j$r d|_YŒƒwxYwdS)Nztrying lock for %rT)r;z locked %rF)rئrاrr’rDrr‡)rArہrs rrبzBoundedSemaphore.try_lock÷s¢€à!ً ً ˆHفڈLٹLذ-¨xر8ش8ذ8فکX¸ذ=ر=ش=ˆDŒIً ط” ×!ز!ر#ش#ذ#ُ—’ک[¨(ر3ش3ذ3طگtگtُّ ش+ً !ً !ً !ط گ” گ گ ً !ًّّّˆus·A.ء.BآBcَX—|jپ"|j ¦«d|_dSdSr)r’rRrQs rrRzBoundedSemaphore.releases1€طŒ9ذ طŒI×زرشذطˆDŒIˆIˆIً!ذ rr`)rarbrcr–rgrhrrer'ع gettempdirr=r>rnr)rdrfrBعSequencer"r#r»rءr·rDrکrبrRr،r¢s@rr¬r¬¢sمّ€€€€€€ً ً ًŒ/ک$ش ذذرً (ط :ط,کش,ر.ش.ط*9ط1Gط26ًًàًًًًً ً ًً” ش'ً ًœ¨ش.ًً!œ/¨$ش/ًًًًًًً:Cکvœ¨w¬|ش<ًCًCًCًCً f¤o°g´lش&Cًًًًً g¤lً ً ً ً ً+/ط15ط26ً ًà” ش'ًًœ¨ش.ًً!œ/¨$ش/ً ً Œکش ًًًًً0 &¤/°(ش";ً ہً ً ً ً ًًًًًًًrr¬cَہ‡—eZdZdZddej¦«eedfdede j ededed e j ed e j ede j e fˆfd„ ZˆxZS) عNamedBoundedSemaphorea، Bounded semaphore to prevent too many parallel processes from running It's also possible to specify a timeout when acquiring the lock to wait for a resource to become available. This is very similar to `threading.BoundedSemaphore` but works across multiple processes and across multiple operating systems. Because this works across multiple processes it's important to give the semaphore a name. This name is used to create the lock files. If you don't specify a name, a random name will be generated. This means that you can't use the same semaphore in multiple processes unless you pass the semaphore object to the other processes. >>> semaphore = NamedBoundedSemaphore(2, name='test') >>> str(semaphore.get_filenames()[0]) '...test.00.lock' >>> semaphore = NamedBoundedSemaphore(2) >>> 'bounded_semaphore' in str(semaphore.get_filenames()[0]) True Nr®Tr¯r0r°r±r9r:r;c َٹ•—|€dtjdd¦«z}t¦« |||||||¦«dS)Nzbounded_semaphore.%dri@B)r¾عrandintrœrBr´s €rrBzNamedBoundedSemaphore.__init__%s[ّ€ًˆ<ط)F¬N¸1¸gر,Fش,FرFˆDف ‰Œ×زطططططططٌ ô ً ً ً r)rarbrcr–r'rثr=r>rnrgrhr)rdrfrBr،r¢s@rrخrخsثّ€€€€€ًًً6&*ط :ط,کش,ر.ش.ط*9ط1Gط26ً ً àً ًŒoکcش"ً ًً ً ً ً” ش'ً ًœ¨ش.ً ً!œ/¨$ش/ً ً ً ً ً ً ً ً ً ً rrخ)T),rir¦r1عloggingr+r"r¾r'rFrgr|عrrrع getLoggerrarئr=r>r?rzع EXCLUSIVEr{r—ع__all__عUnionr)r#rکrqrعcontextmanagerrfrmrkr عABCr8rrڑr¤r¬rخrrrْrظs¤ًط € € € ط € € € طذذذط€€€ط € € € ط€€€ط € € € ط€€€ط€€€ط € € € ط€€€à0ذ0ذ0ذ0ذ0ذ0ذ0ذ0ذ0ذ0à ˆش ک8ر $ش $€à€طذط ذطش!ش+¨iش.Aش.NرN€ًطً€ً Œ<ککWœ\ذ)ش*€ً:>ًFًFًFگF”JًF¨F¬JًFہ&ؤ*ًFًFًFًFً2شًً1$ً1$طً1$àً1$ً„_گV”Yشً1$ً1$ً1$ٌشً1$ًhAًAًAًAًAˆsŒwٌAôAًAًHbًbًbًbًbˆ8ٌbôbًbًJ0!ً0!ً0!ً0!ً0!ˆDٌ0!ô0!ً0!ًf%ً%ً%ً%ً%کٌ%ô%ً%ً4gًgًgًgًgگxٌgôgًgًT- ً- ً- ً- ً- ذ,ٌ- ô- ً- ً- ً- r