L iddlZddlmZmZddlmZmZddlmZddl m Z edZ e dddge d dd gd Z y) N)Paralleldelayed)concurrency_safe_rename make_memmap) with_numpy) parametrizec|jdj}dtjz}tjdz}t ||d|}|j |k(sJy)Nz test.mmapzw+)shapemodeoffset)joinstrpathmmapALLOCATIONGRANULARITYrr)tmpdirfnamesizer memmap_objs `/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/joblib/test/test_backports.py test_memmapr sZ KK $ , ,E t)) )D  ' '! +FU$T&IJ    && & dst_contentz dst contentbackend threadingctdDcgc]}|jd|z}}|D]}|jd|jd|j|td|fd|Dj sJj dk(sJ|D]}|j sJycc}w)Nzsrc_%dz src contentdst)n_jobsrc3rK|].}tt|jj0yw)N)rrr).0src_pathdst_paths r z/test_concurrency_safe_rename..s4(  )'()9)98;K;KL(s47)rangerwriterexistsread)rrri src_pathsr#r$s @rtest_concurrency_safe_renamer,s5:!H=qX\*=I=&}%&{{5!H{#'HAw'(!( ??   ==?m ++ +%??$$$%>sC) rjoblibrrjoblib.backportsrrjoblib.test.commonrjoblib.testingrrr,rrr2s\ $A)& ' ' ]T=12 Y{+,%-3%r