Ë
    æÿæi‡  ã            
       óÈ  — d dl Z d dlmZmZmZ d dlmZmZmZm	Z	m
Z
mZmZ d dlmZmZmZ d dlmZ d dlmZmZ  edeeg«      d„ «       Z edeeg«      d	„ «       Zeed
„ «       «       Zeed„ «       «       Z edddg«      d„ «       Zd„ Zd„ Zee eddd e«        e«       g«       edeeg«      d„ «       «       «       «       Z edeeg«      d„ «       Z edeeg«      d„ «       Zy)é    N)ÚLokyBackendÚMultiprocessingBackendÚThreadingBackend)ÚBACKENDSÚDEFAULT_BACKENDÚEXTERNAL_BACKENDSÚParallelÚdelayedÚparallel_backendÚparallel_config)ÚnpÚwith_multiprocessingÚ
with_numpy)Úcheck_memmap)ÚparametrizeÚraisesÚcontextc                 ó&  — t        «       j                  } | d«      }	 t        t        «       j                  t        «      sJ ‚	 |j	                  «        t        t        «       j                  «      t        |«      u sJ ‚y # |j	                  «        w xY w)NÚ	threading)r	   Ú_backendÚ
isinstancer   Ú
unregisterÚtype)r   ÚdefaultÚpbs      úl/Volumes/fast/ai/experiments/voice-extract-mac/.venv/lib/python3.12/site-packages/joblib/test/test_config.pyÚtest_global_parallel_backendr      sl   € ä‹j×!Ñ!€Gá	�Ó	€BðÜœ(›*×-Ñ-Ô/?Ô@Ð@Ñ@à
�‰ŒÜ”“
×#Ñ#Ó$¬¨W«Ñ5Ð5Ñ5øð 	�‰�ús   ž$A> Á>Bc                 óÈ   — d„ }|t         d<   	  | d«      5  t        t        «       j                  t        «      sJ ‚	 d d d «       t         d= y # 1 sw Y   ŒxY w# t         d= w xY w)Nc                  ó   — t         t        d<   y )NÚfoo)r   r   © ó    r   Úregister_fooz,test_external_backends.<locals>.register_foo$   s   € Ü*Œ�Šr"   r    )r   r   r	   r   r   )r   r#   s     r   Útest_external_backendsr$   "   s[   € ò+ð  ,Ô�eÑð%Ù�U�^Üœh›j×1Ñ1Ô3CÔDÐDÑD÷ ô ˜eÑ$÷ ˆ^ûô ˜eÑ$ús!   ŽA –%A¼A ÁAÁA Á	A!c                 óŽ  — t        dd| ¬«      5  t        d¬«      5 }t        |j                  t        «      sJ ‚|j
                  dk(  sJ ‚ |d„ t        j                  j                  d«      gdz  D «       «       t        t        j                  | «      «      dkD  sJ ‚	 d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   y xY w)	Né   é   ©Ún_jobsÚ
max_nbytesÚtemp_folderÚ	processes)Úpreferc              3   óF   K  — | ]  } t        t        «      |«      –— Œ y ­w©N©r
   r   ©Ú.0Úas     r   Ú	<genexpr>z2test_parallel_config_no_backend.<locals>.<genexpr>:   s    è ø€ ÐKÑ0J¨1Ð#Œg”lÓ# A×&Ñ0Jùó   ‚!é
   r   )r   r	   r   r   r   r)   r   ÚrandomÚlenÚosÚlistdir©ÚtmpdirÚps     r   Útest_parallel_config_no_backendr>   /   s    € ô
 
 ¨a¸VÖ	DÜ˜[Õ)¨QÜ˜aŸj™j¬+Ô6Ð6Ð6Ø—8‘8˜q’=Ð �=ñ ÑK´·±×1AÑ1AÀ"Ó1EÐ0FÈÒ0JÓKÔKÜ”r—z‘z &Ó)Ó*¨QÒ.Ð.Ñ.÷ *÷ 
EÐ	Dß)Ð)ú÷ 
EÐ	Dús#   �B;œBB/ÂB;Â/B8	Â4B;Â;Cc           	      ó–  — t        dd| ¬«      5  t        ddd¬«      5 }t        |j                  t        «      sJ ‚|j
                  dk(  sJ ‚t        t        d¬	«      5   |d
„ t        j                  j                  d«      gdz  D «       «       d d d «       d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   ŒxY w# 1 sw Y   y xY w)Né   r'   r(   r&   r,   Ú1M)r)   r-   r*   zExpected np.memmap instance©Úmatchc              3   óF   K  — | ]  } t        t        «      |«      –— Œ y ­wr/   r0   r1   s     r   r4   z;test_parallel_config_params_explicit_set.<locals>.<genexpr>H   s    è ø€ ÐOÑ4N¨qÐ'”'œ,Ó'¨×*Ñ4Nùr5   r6   )
r   r	   r   r   r   r)   r   Ú	TypeErrorr   r7   r;   s     r   Ú(test_parallel_config_params_explicit_setrF   >   s§   € ô 
 ¨a¸VÖ	DÜ˜Q {¸tÕDÈÜ˜aŸj™j¬+Ô6Ð6Ð6Ø—8‘8˜q’=Ð �=ô œ	Ð)FÖGÙÑO´R·Y±Y×5EÑ5EÀbÓ5IÐ4JÈQÒ4NÓOÔO÷ H÷ E÷ 
EÐ	D÷ HÐGú÷ EÐDú÷ 
EÐ	Dús:   �B?ž?B3Á1B'ÂB3ÂB?Â'B0Â,B3Â3B<	Â8B?Â?CÚparamr-   Úrequirec                 ó®   — t        t        | › d�¬«      5  t        di | di¤Ž5  t        «        d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   y xY w)Nz=wrong is not a validrB   Úwrongr!   )r   Ú
ValueErrorr   r	   )rG   s    r   Útest_parallel_config_bad_paramsrL   K   sJ   € ô 
”
 U GÐ+@Ð"AÖ	BÜÑ0  wÐ/Ó0ÜŒJ÷ 1÷ 
CÐ	Bß0Ð0ú÷ 
CÐ	Bús   •A£?®A¿A	ÁAÁAc                  óÌ  — t        t        d¬«      5  t        d¬«      5  	 d d d «       d d d «       t        t        d¬«      5  t        d¬«      5  	 d d d «       d d d «       t        t        d¬«      5  t        t        t           d¬«      5  	 d d d «       d d d «       y # 1 sw Y   Œ~xY w# 1 sw Y   Œ‚xY w# 1 sw Y   ŒfxY w# 1 sw Y   ŒjxY w# 1 sw Y   ŒBxY w# 1 sw Y   y xY w)Nz'only supported when backend is not NonerB   r'   ©Úinner_max_num_threads)Úbackend_paramz'only supported when backend is a string)ÚbackendrP   )r   rK   r   r   r   r!   r"   r   Ú'test_parallel_config_constructor_paramsrR   T   s°   € ô 
”
Ð"KÖ	LÜ°1Ö5Ø÷ 6÷ 
Mô 
”
Ð"KÖ	LÜ¨1Ö-Ø÷ .÷ 
Mô 
”
Ð"KÖ	LÜ¤X¬oÑ%>ÈaÖPØ÷ Q÷ 
MÐ	L÷ 6Ð5ú÷ 
MÐ	Lú÷
 .Ð-ú÷ 
MÐ	Lú÷
 QÐPú÷ 
MÐ	Lúsi   ’B*ŸB¡B*ÁCÁB6ÁCÁ2CÂCÂCÂB'	Â#B*Â*B3Â6B?	Â;CÃCÃC	ÃCÃC#c                  ó–  — t        d¬«      5  t        «       } t        | j                  t        t
           «      sJ ‚| j                  dk(  sJ ‚	 d d d «       t        d¬«      5  t        d¬«      5  t        «       } t        | j                  t        «      sJ ‚| j                  dk(  sJ ‚	 d d d «       d d d «       t        d¬«      5  t        d¬«      5  t        «       } | j                  dk(  sJ ‚| j                  dk(  sJ ‚	 d d d «       d d d «       y # 1 sw Y   ŒÃxY w# 1 sw Y   ŒuxY w# 1 sw Y   ŒyxY w# 1 sw Y   Œ6xY w# 1 sw Y   y xY w)Nr&   ©r)   r   ©rQ   éd   )Úverbose)	r   r	   r   r   r   r   r)   r   rW   )r=   s    r   Útest_parallel_config_nestedrX   d   sþ   € ô 
 Ö	"Ü‹JˆÜ˜!Ÿ*™*¤h¬Ñ&?Ô@Ð@Ð@Ø�x‰x˜1Š}Ð‰}÷ 
#ô
 
 Ö	-Ü AÖ&Ü“
ˆAÜ˜aŸj™jÔ*:Ô;Ð;Ð;Ø—8‘8˜q’=Ð ‘=÷ '÷ 
.ô 
 Ö	%Ü AÖ&Ü“
ˆAØ—9‘9 Ò#Ð#Ð#Ø—8‘8˜q’=Ð ‘=÷ '÷ 
&Ð	%÷ 
#Ð	"ú÷ 'Ð&ú÷ 
.Ð	-ú÷ 'Ð&ú÷ 
&Ð	%úsS   �?DÁ!D'Á.8DÂ'D'ÃD?Ã-D3Ã>D?ÄDÄD$	Ä D'Ä'D0Ä3D<	Ä8D?Ä?ErQ   Úmultiprocessingr   c                 ód   — t        t        d¬«      5   | |d¬«       d d d «       y # 1 sw Y   y xY w)Nz#does not acc.*inner_max_num_threadsrB   r'   rN   )r   ÚAssertionError)r   rQ   s     r   Ú1test_threadpool_limitation_in_child_context_errorr\   z   s&   € ô 
”Ð&LÖ	MÙ�¨qÕ1÷ 
N×	MÑ	Mús   ’&¦/c                 ór  —  | dd¬«      5  t        d ¬«      5 }|j                  dk(  sJ ‚	 d d d «       d d d «        | d¬«      5  t        «       j                  }t        d ¬«      5 }|j                  |k(  sJ ‚	 d d d «       d d d «       y # 1 sw Y   Œ_xY w# 1 sw Y   ŒcxY w# 1 sw Y   Œ*xY w# 1 sw Y   y xY w)Nr   r&   ©rQ   r)   rT   rU   ©r	   r)   )r   r=   Údefault_n_jobss      r   Útest_parallel_n_jobs_nonera   †   s–   € ñ 
˜¨QÖ	/Ü˜TÕ" aØ—8‘8˜q’=Ð ‘=÷ #÷ 
0ñ 
˜Ö	%Ü!›×*Ñ*ˆÜ˜TÕ" aØ—8‘8˜~Ò-Ð-Ñ-÷ #÷ 
&Ð	%÷ #Ð"ú÷ 
0Ð	/ú÷ #Ð"ú÷ 
&Ð	%úsE   ‹B˜B	«BÁ!B-Á%B!Á8B-Â	B	ÂBÂBÂ!B*	Â&B-Â-B6c                 óâ   —  | dd¬«      5   | dd ¬«      5  t        «       5 }|j                  dk(  sJ ‚	 d d d «       d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   ŒxY w# 1 sw Y   y xY w)Nr   r&   r^   r'   r_   )r   r=   s     r   Ú test_parallel_config_n_jobs_nonerc   ”   s[   € ñ
 
˜¨QÖ	/Ù˜[°Ö6ä”˜qØ—x‘x 1’}Ð$‘}÷ ÷ 7÷ 
0Ð	/÷ �ú÷ 7Ð6ú÷ 
0Ð	/ús7   ‹A%–A¡A´A¼A%ÁAÁAÁA"	ÁA%Á%A.) r9   Újoblib._parallel_backendsr   r   r   Újoblib.parallelr   r   r   r	   r
   r   r   Újoblib.test.commonr   r   r   Újoblib.test.test_parallelr   Újoblib.testingr   r   r   r$   r>   rF   rL   rR   rX   r\   ra   rc   r!   r"   r   Ú<module>ri      so  ðÛ 	÷ñ ÷
÷ ñ ÷ DÑ CÝ 2ß .ñ ˆY˜Ð*:Ð;Ó<ñ6ó =ð6ñ ˆY˜Ð*:Ð;Ó<ñ	%ó =ð	%ð Øñ
/ó ó ð
/ð ØñPó ó ðPñ ˆW�x Ð+Ó,ñó -ðòò !ð, ØÙØØ˜Ñ%;Ó%=Ñ?OÓ?QÐRóñ ˆY˜Ð*:Ð;Ó<ñ2ó =ó	ó ó ð2ñ
 ˆY˜Ð*:Ð;Ó<ñ
.ó =ð
.ñ ˆY˜Ð*:Ð;Ó<ñ%ó =ñ%r"   