§
    €zIfòG  ã                   ó`  — d dl mZmZmZ d dlZd dlZd dlZd dlmZ d dlm	Z	 d dl
mZ ddlmZmZmZ ddlmZmZ dd	lmZ  ej        d
¦  «        Z ej        d¦  «        Zd dlmZmZmZ d dlm
Z
 d dlmZmZmZ d„ Z d;d„Z!d„ Z"d„ Z#d„ Z$d„ Z%d„ Z&ej'         (                    dddg¦  «        d„ ¦   «         Z)d„ Z* G d„ de+¦  «        Z,d<d„Z-d„ Z.d „ Z/ej'         (                    d! e0 e1d¦  «        ¦  «        ¦  «        d"„ ¦   «         Z2d#„ Z3d$„ Z4d%„ Z5d&„ Z6d'„ Z7d(„ Z8d)„ Z9d*„ Z:d+„ Z;d,„ Z<d-„ Z=ej'         (                    d.d/d0g¦  «        ej'         >                    ej?        d1k    o
ej?        d2k    d3¬4¦  «        d5„ ¦   «         ¦   «         Z@d6„ ZAej'         (                    d7d8d9g¦  «        d:„ ¦   «         ZBdS )=é    )Úprint_functionÚdivisionÚabsolute_importN©Úrandom)Úuuid4)Úsleepé   )ÚParallelÚdelayedÚparallel_config)ÚThreadingBackendÚAutoBatchingMixin)ÚDaskDistributedBackendÚdistributedÚdask)ÚClientÚLocalClusterÚ
get_client)Útime)ÚclusterÚincÚcleanupc                  ó   — d S ©N© )ÚargsÚkwargss     úI/var/www/piapp/venv/lib/python3.11/site-packages/joblib/test/test_dask.pyÚnoopr       s   € Ø€Dó    çš™™™™™©?c                 óF   — t          |¦  «         | rt          d¦  «        ‚d S )Nzcondition evaluated to True)r	   Ú
ValueError)Ú	conditionÚdurations     r   Úslow_raise_value_errorr'      s.   € Ý	ˆ(�O„O€OØð 8ÝÐ6Ñ7Ô7Ð7ð8ð 8r!   c                 óÂ   ‡ — |                      d„ ¦  «        }i }|                     ¦   «         D ]0\  }}t          ˆ fd„t          |¦  «        D ¦   «         ¦  «        ||<   Œ1|S )Nc                 ó   — | j         S r   )Úlog)Údask_workers    r   ú<lambda>zcount_events.<locals>.<lambda>$   s   € °;´?€ r!   c                 ó,   •— g | ]}|d          ‰k    ¯|‘ŒS ©é   r   )Ú.0ÚeventÚ
event_names     €r   ú
<listcomp>z count_events.<locals>.<listcomp>'   s1   ø€ ð :ð :ð :¨Ø"'¨¤(¨jÒ"8Ð"8ð  %Ø"8Ð"8Ð"8r!   )ÚrunÚitemsÚlenÚlist)r2   ÚclientÚworker_eventsÚevent_countsÚwÚeventss   `     r   Úcount_eventsr=   #   s‚   ø€ Ø—J’JÐBÐBÑCÔC€MØ€LØ"×(Ò(Ñ*Ô*ð ;ð ;‰	ˆˆ6Ýð :ð :ð :ð :µ$°v±,´,ð :ñ :ô :ñ ;ô ;ˆ�Q‰ˆàÐr!   c           
      ó  — t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          ¦   «         d„ t	          d¦  «        D ¦   «         ¦  «        }|d„ t	          d¦  «        D ¦   «         k    sJ ‚t          j        t          ¦  «        5   t          ¦   «         d„ t	          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y    t          ¦   «         d	„ t	          d¦  «        D ¦   «         ¦  «        }|d
„ t	          d¦  «        D ¦   «         k    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )NÚaddress©Úloopr   ©Úbackendc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   ©r   r   ©r0   Úis     r   ú	<genexpr>ztest_simple.<locals>.<genexpr>0   ó0   è è € Ð DÐ D°Q ¥­¡¤¨a¡¤Ð DÐ DÐ DÐ DÐ DÐ Dr!   é
   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r   ©r   rF   s     r   r3   ztest_simple.<locals>.<listcomp>1   ó   € Ð9Ð9Ð9¨!�s 1™vœvÐ9Ð9Ð9r!   c              3   óX   K  — | ]%} t          t          ¦  «        |d k    ¦  «        V — Œ&dS )é   N)r   r'   rF   s     r   rH   ztest_simple.<locals>.<genexpr>4   sM   è è € ð 3ð 3Ø#$ð  ?�wÕ'=Ñ>Ô>¸qÀAºvÑFÔFð 3ð 3ð 3ð 3ð 3ð 3r!   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   ztest_simple.<locals>.<genexpr>7   rI   r!   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r   rL   rF   s     r   r3   ztest_simple.<locals>.<listcomp>8   rM   r!   )r   r   r   r   ÚrangeÚpytestÚraisesr$   ©rA   ÚsÚaÚbr8   Úseqs         r   Útest_simplerZ   ,   s„  € Ý	‰Œð :‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 
	:°Ý ¨Ð0Ñ0Ô0ð 	:ð 	:Ø •h‘j”jÐ DÐ D½%À¹)¼)Ð DÑ DÔ DÑDÔD�ØÐ9Ð9­u°R©y¬yÐ9Ñ9Ô9Ò9Ð9Ð9Ð9å”]¥:Ñ.Ô.ð 3ð 3Ø•H‘J”Jð 3ð 3Ý(-¨b©	¬	ð3ñ 3ô 3ñ 3ô 3ð 3ð3ð 3ð 3ñ 3ô 3ð 3ð 3ð 3ð 3ð 3ð 3øøøð 3ð 3ð 3ð 3ð !•h‘j”jÐ DÐ D½%À¹)¼)Ð DÑ DÔ DÑDÔD�ØÐ9Ð9­u°R©y¬yÐ9Ñ9Ô9Ò9Ð9Ð9Ð9Ð9ð	:ð 	:ð 	:ñ 	:ô 	:ð 	:ð 	:ð 	:ð 	:ð 	:ð 	:øøøð 	:ð 	:ð 	:ð 	:ð
	:ð 
	:ð 
	:ñ 
	:ô 
	:ð 
	:ð 
	:ð 
	:ð 
	:ð 
	:ð 
	:øøøð 
	:ð 
	:ð 
	:ð 
	:ð:ð :ð :ñ :ô :ð :ð :ð :ð :ð :ð :ð :øøøð :ð :ð :ð :ð :ð :s}   �E4­E¾A'EÂ%/C 	ÃEÃ C$Ã$EÃ'C$Ã(AEÄ9EÅE	Å	EÅE	ÅEÅE4ÅE 	Å E4Å#E 	Å$E4Å4E8Å;E8c                 ót  — t           j        t          j        u sJ ‚t          ¦   «         5 \  }\  }}t	          |d         | ¬¦  «        5 }t          d¬¦  «        5  t          ¦   «         5 }|j        }t          |t           ¦  «        sJ ‚|j	        |u sJ ‚|j
        dk    sJ ‚ |d„ t          t          d¦  «        ¦  «        D ¦   «         ¦  «         |j
        dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )	Nr?   r@   r   rB   r/   c              3   óF   K  — | ]} t          d „ ¦  «        ¦   «         V — ŒdS )c                  ó   — d S r   r   r   r!   r   r,   z?test_dask_backend_uses_autobatching.<locals>.<genexpr>.<lambda>M   s   € ¨€ r!   N©r   ©r0   Ú_s     r   rH   z6test_dask_backend_uses_autobatching.<locals>.<genexpr>L   sH   è è € ð ð àð .�  Ñ-Ô-Ñ/Ô/ðð ð ð ð ð r!   ç     ˆÃ@rJ   )r   Úcompute_batch_sizer   r   r   r   r   Ú_backendÚ
isinstanceÚparallelÚ_effective_batch_sizerR   Úint)rA   rV   rW   rX   r8   re   rC   s          r   Ú#test_dask_backend_uses_autobatchingrh   ;   sb  € Ý"Ô5Ý Ô3ð4ð 4ð 4ð 4õ 
‰Œð >‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	>°Ý ¨Ð0Ñ0Ô0ð >ð >Ý‘Z”Zð > 8ð 'Ô/�GÝ% gÕ/EÑFÔFÐFÐFÐFØ"Ô+¨xÐ7Ð7Ð7Ð7Ø"Ô8¸AÒ=Ð=Ð=Ð=ð �Hð ð å!&¥s¨3¡x¤x¡¤ðñ ô ñ ô ð ð #Ô8¸2Ò=Ð=Ð=Ð=Ð=ð>ð >ð >ñ >ô >ð >ð >ð >ð >ð >ð >øøøð >ð >ð >ð >ð>ð >ð >ñ >ô >ð >ð >ð >ð >ð >ð >øøøð >ð >ð >ð >ð	>ð 	>ð 	>ñ 	>ô 	>ð 	>ð 	>ð 	>ð 	>ð 	>ð 	>øøøð 	>ð 	>ð 	>ð 	>ð>ð >ð >ñ >ô >ð >ð >ð >ð >ð >ð >ð >øøøð >ð >ð >ð >ð >ð >s~   ©D-ÁDÁC>Á'A3C'	ÃC>Ã'C+Ã+C>Ã.C+Ã/C>Ã2DÃ>DÄDÄDÄDÄ	D-ÄD	ÄD-ÄD	ÄD-Ä-D1Ä4D1c                  ó   — t          ¦   «         S r   r   r   r!   r   Úrandom2rj   S   s   € Ý‰8Œ8€Or!   c           	      ó‚  — t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          ¦   «         d„ t	          d¦  «        D ¦   «         ¦  «        \  }}||k    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr?   r@   r   rB   c              3   óN   K  — | ] } t          t          ¦  «        ¦   «         V — Œ!d S r   )r   rj   rF   s     r   rH   z3test_dont_assume_function_purity.<locals>.<genexpr>[   s3   è è € Ð!GÐ!G¸Ð"2¥'­'Ñ"2Ô"2Ñ"4Ô"4Ð!GÐ!GÐ!GÐ!GÐ!GÐ!Gr!   r
   ©r   r   r   r   rR   )rA   rV   rW   rX   r8   ÚxÚys          r   Ú test_dont_assume_function_purityrp   W   s  € Ý	‰Œð ‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	°Ý ¨Ð0Ñ0Ô0ð ð Ø!•x‘z”zÐ!GÐ!G½eÀA¹h¼hÐ!GÑ!GÔ!GÑGÔG‘��1Ø˜A’v�v�v�v�vðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sW   �B4­B¾:BÁ9BÂB	Â	BÂB	ÂBÂB4ÂB 	Â B4Â#B 	Â$B4Â4B8Â;B8ÚmixedTFc                 ó�  — ddl m} |sd„ t          d¦  «        D ¦   «         }d}nd„ t          d¦  «        D ¦   «         }d}t           ||¦  «        ¦  «        |k    sJ ‚t	          ¦   «         5 \  }\  }}t          |d         | ¬	¦  «        5 }t          d
¬¦  «        5   t          dd¬¦  «        |¦  «        }	d d d ¦  «         n# 1 swxY w Y   d„ }
|                     dd¦  «        }| 	                    |
¦  «        }t          d„ |D ¦   «         ¦  «        sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   )ÚBatchc                 óH   — g | ]} t          t          ¦  «        |¦  «        ‘Œ S r   rE   rF   s     r   r3   z&test_dask_funcname.<locals>.<listcomp>c   s&   € Ð3Ð3Ð3 Q�•�‘”˜a‘”Ð3Ð3Ð3r!   é   Úbatch_of_inc_4_callsc                 óŒ   — g | ]A}|d z  r t          t          ¦  «        |¦  «        n t          t          ¦  «        |¦  «        ‘ŒBS )r
   )r   Úabsr   rF   s     r   r3   z&test_dask_funcname.<locals>.<listcomp>f   sN   € ð 
ð 
ð 
Ø>?˜q 1™uÐ9ˆL�G•C‰LŒL˜‰OŒOˆO¨,­'µ#©,¬,°q©/¬/ð
ð 
ð 
r!   Úmixed_batch_of_inc_4_callsr?   r@   r   rB   r
   Úall)Ú
batch_sizeÚpre_dispatchc                 ó*   — t          | j        ¦  «        S r   )r7   Útransition_log)Údask_schedulers    r   Úfztest_dask_funcname.<locals>.fr   s   € Ý˜NÔ9Ñ:Ô:Ð:r!   Ú4Ú2c              3   ó*   K  — | ]}d |d         v V — ŒdS )Úbatch_of_incr   Nr   )r0   Útups     r   rH   z%test_dask_funcname.<locals>.<genexpr>v   s+   è è € Ð?Ð?°C�~¨¨Q¬Ð/Ð?Ð?Ð?Ð?Ð?Ð?r!   )Újoblib._daskrs   rR   Úreprr   r   r   r   ÚreplaceÚrun_on_schedulerrz   )rA   rq   rs   ÚtasksÚ
batch_reprrV   rW   rX   r8   r`   r€   r*   s               r   Útest_dask_funcnamerŒ   _   sw  € à"Ð"Ð"Ð"Ð"Ð"Øð 2Ø3Ð3­%°©(¬(Ð3Ñ3Ô3ˆØ+ˆ
ˆ
ð
ð 
ÝCHÈÁ8Ä8ð
ñ 
ô 
ˆð 2ˆ
å���e‘”ÑÔ Ò+Ð+Ð+Ð+å	‰Œð 	@‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	@°Ý ¨Ð0Ñ0Ô0ð Fð FØ>•H¨¸Ð>Ñ>Ô>¸uÑEÔE�ðFð Fð Fñ Fô Fð Fð Fð Fð Fð Fð Føøøð Fð Fð Fð Fð;ð ;ð ;à#×+Ò+¨C°Ñ5Ô5ˆJØ×)Ò)¨!Ñ,Ô,ˆCÝÐ?Ð?¸3Ð?Ñ?Ô?Ñ?Ô?Ð?Ð?Ð?Ð?ð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@øøøð 	@ð 	@ð 	@ð 	@ð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@øøøð 	@ð 	@ð 	@ð 	@ð 	@ð 	@s[   Á,D;Â
D#ÂCÂ6D#ÃCÃD#Ã	CÃ
AD#ÄD;Ä#D'	Ä'D;Ä*D'	Ä+D;Ä;D?ÅD?c                  óV  ‡‡‡— d„ t          d¦  «        D ¦   «         } t          j        d¦  «        Š‰                     t	          d¦  «        ¦  «        Šdˆˆfd„	Št          dd¬¦  «        }t          |¦  «        }	 t          d	¬
¦  «        5   t          ¦   «         ˆfd„| D ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   | d„ t          d¦  «        D ¦   «         k    sJ ‚t          d|¦  «        }t          |                     ¦   «         ¦  «        dk    sJ ‚t          d„ |D ¦   «         ¦  «        sJ ‚t          d	¬
¦  «        5   t          ¦   «         ˆˆfd„| D ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   t          d|¦  «        }t          |                     ¦   «         ¦  «        dk    sJ ‚t          d„ |D ¦   «         ¦  «        sJ ‚	 |                     d¬¦  «          |j        d¬¦  «         d S # |                     d¬¦  «          |j        d¬¦  «         w xY w)Nc                 ó   — g | ]}g ‘ŒS r   r   r_   s     r   r3   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>„   s   € Ð$Ð$Ð$�AˆRÐ$Ð$Ð$r!   éd   Únumpyg    €„.Ac                 óŽ   •— |�‰j                              |‰¦  «         |                      t          ¦   «         j        ¦  «         | S r   )ÚtestingÚassert_array_equalÚappendr   Úhex)Úlist_ÚdataÚXÚnps     €€r   Úisolated_operationzCtest_no_undesired_distributed_cache_hit.<locals>.isolated_operationˆ   s>   ø€ ØÐØŒJ×)Ò)¨$°Ñ2Ô2Ð2Ø�Š•U‘W”W”[Ñ!Ô!Ð!Øˆr!   r/   r
   )Ú	n_workersÚthreads_per_workerr   rB   c              3   óH   •K  — | ]} t          ‰¦  «        |¦  «        V — Œd S r   r^   )r0   r–   rš   s     €r   rH   z:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>“   sH   øè è € ð ð Ø7<Ð+•Ð*Ñ+Ô+¨EÑ2Ô2ðð ð ð ð ð r!   c                 ó   — g | ]}g ‘ŒS r   r   r_   s     r   r3   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>™   s   € Ð0Ð0Ð0 ˜Ð0Ð0Ð0r!   úreceive-from-scatterr   c                 ó4   — g | ]}t          |¦  «        d k    ‘ŒS r.   ©r6   ©r0   Úrs     r   r3   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>    ó"   € Ð-Ð-Ð- A•C˜‘F”F˜a’KÐ-Ð-Ð-r!   c              3   óL   •K  — | ]} t          ‰¦  «        |‰¬ ¦  «        V — ŒdS ))r—   Nr^   )r0   r–   r˜   rš   s     €€r   rH   z:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>¥   sM   øè è € ð ð Ø?DÐ+•Ð*Ñ+Ô+¨E¸Ð:Ñ:Ô:ðð ð ð ð ð r!   c                 ó4   — g | ]}t          |¦  «        d k    ‘ŒS r.   r¡   r¢   s     r   r3   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>¬   r¤   r!   é   ©Útimeoutr   )rR   rS   ÚimportorskipÚarangerg   r   r   r   r   r=   ÚsumÚvaluesrz   Úclose)Úlistsr   r8   ÚresÚcountsr˜   rš   r™   s        @@@r   Ú'test_no_undesired_distributed_cache_hitr²   y   s  øøø€ ð %Ð$�˜s™œÐ$Ñ$Ô$€EÝ	Ô	˜WÑ	%Ô	%€BØ
�	Š	•#�c‘(”(ÑÔ€Aðð ð ð ð ð ð õ  Q¸1Ð=Ñ=Ô=€GÝ�G‰_Œ_€Fð"Ý VÐ,Ñ,Ô,ð 	ð 	à•(‘*”*ð ð ð ð Ø@Eðñ ô ñ ô ˆCð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð Ð0Ð0¥U¨3¡Z¤ZÐ0Ñ0Ô0Ò0Ð0Ð0Ð0õ
 Ð4°fÑ=Ô=ˆÝ�6—=’=‘?”?Ñ#Ô# qÒ(Ð(Ð(Ð(ÝÐ-Ð-¨Ð-Ñ-Ô-Ñ.Ô.Ð.Ð.Ð.å VÐ,Ñ,Ô,ð 	ð 	ð •(‘*”*ð ð ð ð ð ØHMðñ ô ñ ô ˆCð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ Ð4°fÑ=Ô=ˆÝ�6—=’=‘?”?Ñ#Ô# aÒ'Ð'Ð'Ð'ÝÐ-Ð-¨Ð-Ñ-Ô-Ñ.Ô.Ð.Ð.Ð.Ð.à�Š˜RˆÑ Ô Ð ØˆŒ˜bÐ!Ñ!Ô!Ð!Ð!Ð!øð 	�Š˜RˆÑ Ô Ð ØˆŒ˜bÐ!Ñ!Ô!Ð!Ð!øøøsV   Á;G? Â$B;Â/G? Â;B?Â?G? ÃB?ÃBG? Å%E8Å,G? Å8E<Å<G? Å?E<Æ AG? Ç?)H(c                   ó$   — e Zd Zd„ Zd„ ZeZd„ ZdS )ÚCountSerializedc                 ó"   — || _         d| _        d S )Nr   )rn   Úcount)Úselfrn   s     r   Ú__init__zCountSerialized.__init__³   s   € ØˆŒØˆŒ
ˆ
ˆ
r!   c                 ó4   — | j         t          |d|¦  «        z   S )Nrn   )rn   Úgetattr)r·   Úothers     r   Ú__add__zCountSerialized.__add__·   s   € ØŒv�  s¨EÑ2Ô2Ñ2Ð2r!   c                 ó@   — | xj         dz  c_         t          | j        ffS )Nr/   )r¶   r´   rn   )r·   s    r   Ú
__reduce__zCountSerialized.__reduce__¼   s    € Øˆ
Œ
�a‰ˆ
Œ
Ý $¤& Ð+Ð+r!   N)Ú__name__Ú
__module__Ú__qualname__r¸   r¼   Ú__radd__r¾   r   r!   r   r´   r´   ²   sH   € € € € € ðð ð ð3ð 3ð 3ð €Hð,ð ,ð ,ð ,ð ,r!   r´   c                 ó   — | |z   |z   |z   |z   S r   r   )rW   rX   ÚcÚdÚes        r   Úadd5rÇ   Á   s   € Øˆq‰5�1‰9�q‰=˜1ÑÐr!   c                 óh  — t          d¦  «        }t          d¦  «        }t          d¦  «        }t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d||g¬¦  «        5  t	          t
          ¦  «        } ||||dd	¬
¦  «         ||||d	d¬
¦  «         |||||d	¬
¦  «         ||||||¬
¦  «        g}	d„ |	D ¦   «         }
 t          ¦   «         |	¦  «        }d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  t          d| d¬¦  «        5  	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   ||
k    sJ ‚|j
        dk    sJ ‚|j
        dk    sJ ‚|j
        dv sJ ‚d S )Nr/   r
   rO   r?   r@   r   )rC   Úscatterru   é   )rÅ   rÆ   c                 ó&   — g | ]\  }}} ||i |¤Ž‘ŒS r   r   )r0   Úfuncr   r   s       r   r3   z'test_manual_scatter.<locals>.<listcomp>Ò   s=   € ð =ð =ð =Ù 2  d¨Fð !˜D $Ð1¨&Ð1Ð1ð =ð =ð =r!   )rC   rA   rÉ   )ru   é   )r´   r   r   r   r   rÇ   r   rS   rT   Ú	TypeErrorr¶   )rA   rn   ro   ÚzrV   rW   rX   r8   r€   rŠ   ÚexpectedÚresultss               r   Útest_manual_scatterrÒ   Å   s'  € Ý˜ÑÔ€AÝ˜ÑÔ€AÝ˜ÑÔ€Aå	‰Œð ‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	°Ý ¨¸!¸Q¸Ð@Ñ@Ô@ð ,ð ,Ý�D‘M”M�Ø˜˜1˜a  a¨1Ð-Ñ-Ô-Ø˜˜1˜a  a¨1Ð-Ñ-Ô-Ø˜˜1˜a  a¨1Ð-Ñ-Ô-Ø˜˜1˜a  a¨1Ð-Ñ-Ô-ð/�ð=ð =Ø6;ð=ñ =ô =�à$�(™*œ* UÑ+Ô+�ð,ð ,ð ,ñ ,ô ,ð ,ð ,ð ,ð ,ð ,ð ,øøøð ,ð ,ð ,ð ,õ ”�yÑ)Ô)ð ð Ý$¨V¸$ÈÐJÑJÔJð ð Øðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð" �hÒÐÐÐð Œ7�aŠ<ˆ<ˆ<ˆ<ØŒ7�aŠ<ˆ<ˆ<ˆ<ð
 Œ7�fÐÐÐÐÐÐs¢   ¼E:ÁE#Á.A6C0Ã$E#Ã0C4Ã4E#Ã7C4Ã8E#ÄEÄ'D5	Ä)EÄ5D9Ä9EÄ<D9Ä=EÅ E#ÅEÅE#ÅEÅE#ÅE:Å#E'	Å'E:Å*E'	Å+E:Å:E>ÆE>c           	      ó’  ‡	— t          j        d¦  «        }|                     t          d¦  «        |j        ¬¦  «        Š	|                     t          d¦  «        |j        ¬¦  «        }‰	gdz  |gdz  z   }t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          ¦   «         d	„ t          |¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   t          d
|¦  «        }||d                  ||d                  z   dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          ¦   «         ˆ	fd„t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   t          d
|¦  «        }||d                  dk    sJ ‚||d                  dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr�   ra   )ÚdtyperO   r?   r@   r   rB   c              3   ó^   K  — | ](\  }} t          t          ¦  «        ||||¬ ¦  «        V — Œ)dS ))ÚoptN©r   r    )r0   rG   r—   s      r   rH   z$test_auto_scatter.<locals>.<genexpr>õ   s[   è è € ð Fð FÙ&˜q $ð )�7¥4™=œ=¨¨t°Q¸DÐAÑAÔAð Fð Fð Fð Fð Fð Fr!   rŸ   r
   c              3   ód   •K  — | ]*} t          t          ¦  «        ‰d d…         |¦  «        V — Œ+d S )NrO   r×   )r0   rG   Údata1s     €r   rH   z$test_auto_scatter.<locals>.<genexpr>   s=   øè è € ÐIÐI¸1˜=�7¥4™=œ=¨¨r°¨r¬°AÑ6Ô6ÐIÐIÐIÐIÐIÐIr!   rÊ   r   )rS   rª   Úonesrg   Úuint8r   r   r   r   Ú	enumerater=   rR   )
Úloop_in_threadr™   Údata2Údata_to_processrV   rW   rX   r8   r±   rÙ   s
            @r   Útest_auto_scatterrà   ê   s  ø€ Ý	Ô	˜WÑ	%Ô	%€BØ�GŠG•C˜‘H”H B¤HˆGÑ-Ô-€EØ�GŠG•C˜‘H”H B¤HˆGÑ-Ô-€EØ�w ‘{¨ w°¡{Ñ3€Oå	‰Œð D‘k�q™&˜1˜aÝ�A�i”L ~Ð6Ñ6Ô6ð 
	D¸&Ý ¨Ð0Ñ0Ô0ð Fð Fð •‘
”
ð Fð FÝ*3°OÑ*DÔ*DðFñ Fô Fñ Fô Fð FðFð Fð Fñ Fô Fð Fð Fð Fð Fð Fð Føøøð Fð Fð Fð Fõ "Ð"8¸&ÑAÔAˆFØ˜!˜Iœ,Ô'¨&°°9´Ô*>Ñ>À!ÒCÐCÐCÐCÐCð
	Dð 
	Dð 
	Dñ 
	Dô 
	Dð 
	Dð 
	Dð 
	Dð 
	Dð 
	Dð 
	Døøøð 
	Dð 
	Dð 
	Dð 
	DðDð Dð Dñ Dô Dð Dð Dð Dð Dð Dð Døøøð Dð Dð Dð Dõ 
‰Œð -‘k�q™&˜1˜aÝ�A�i”L ~Ð6Ñ6Ô6ð 	-¸&Ý ¨Ð0Ñ0Ô0ð Jð JØ•‘
”
ÐIÐIÐIÐIÅÀaÁÄÐIÑIÔIÑIÔIÐIðJð Jð Jñ Jô Jð Jð Jð Jð Jð Jð Jøøøð Jð Jð Jð Jõ "Ð"8¸&ÑAÔAˆFØ˜!˜Iœ,Ô'¨1Ò,Ð,Ð,Ð,Ø˜!˜Iœ,Ô'¨1Ò,Ð,Ð,Ð,Ð,ð	-ð 	-ð 	-ñ 	-ô 	-ð 	-ð 	-ð 	-ð 	-ð 	-ð 	-øøøð 	-ð 	-ð 	-ð 	-ð-ð -ð -ñ -ô -ð -ð -ð -ð -ð -ð -ð -øøøð -ð -ð -ð -ð -ð -s´   ÂEÂ!D8Â2/C-Ã!D8Ã-C1Ã1D8Ã4C1Ã56D8Ä,EÄ8D<	Ä<EÄ?D<	Å EÅEÅEÅ(H<ÆH$Æ1GÇH$ÇGÇH$ÇGÇ;H$ÈH<È$H(	È(H<È+H(	È,H<È<I ÉI Úretry_noc           	      óê  ‡‡‡	‡
‡— t          j        d¦  «        Š
dŠd}ˆ
fd„Š	ˆˆ	fd„Št          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t	          d¬¦  «        5  ‰
                     d	¦  «        Š t          ¦   «         ˆˆfd
„t          |¦  «        D ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr�   rJ   c                 ó.   •— ‰                      | ¦  «        S r   )r¬   )rn   rG   Újr™   s      €r   Úmy_sumz#test_nested_scatter.<locals>.my_sum  s   ø€ Ø�vŠv�a‰yŒyÐr!   c                 óö   •‡ ‡— t          ¦   «         }t          d¬¦  «        5   t          ¦   «         ˆ ˆˆfd„t          ‰¦  «        D ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   t	          |¦  «        S )Nr   rB   c              3   ó\   •K  — | ]&} t          ‰¦  «        ‰|d …         ‰|¦  «        V — Œ'd S r   r^   )r0   rä   ÚarrayrG   rå   s     €€€r   rH   zEtest_nested_scatter.<locals>.outer_function_joblib.<locals>.<genexpr>  sP   øè è € ð !ð !Ø56�•˜‘”  a b b¤	¨1¨aÑ0Ô0ð!ð !ð !ð !ð !ð !r!   )r   r   r   rR   r¬   )rè   rG   r8   rÑ   ÚNUM_INNER_TASKSrå   s   ``  €€r   Úouter_function_joblibz2test_nested_scatter.<locals>.outer_function_joblib  sÔ   øøø€ Ý‘”ˆÝ VÐ,Ñ,Ô,ð 	ð 	Ø •h‘j”jð !ð !ð !ð !ð !ð !Ý:?Ø#ñ;%ô ;%ð!ñ !ô !ñ ô ˆGð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ
 �7‰|Œ|Ðs   ¢3A!Á!A%Á(A%r?   r@   r   rB   i'  c              3   óZ   •K  — | ]%} t          ‰¦  «        ‰|d …         |¦  «        V — Œ&d S r   r^   )r0   rG   Úmy_arrayrê   s     €€r   rH   z&test_nested_scatter.<locals>.<genexpr>   sY   øè è € ð ð à-.ð 3•GÐ1Ñ2Ô2Ø    œ añ)ô )ðð ð ð ð ð r!   )rS   rª   r   r   r   rÚ   r   rR   )rA   rá   ÚNUM_OUTER_TASKSrV   rW   rX   r`   ré   rì   rå   r™   rê   s          @@@@@r   Útest_nested_scatterrî     sõ  øøøøø€ õ 
Ô	˜WÑ	%Ô	%€Bà€OØ€Oðð ð ð ð ðð ð ð ð ð õ 
‰Œð ‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	°Ý ¨Ð0Ñ0Ô0ð ð ØŸ7š7 5™>œ>�Ø•H‘J”Jð ð ð ð ð å27¸Ñ2HÔ2Hðñ ô ñ ô �ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sZ   ·C(ÁCÁ&AB9Â-CÂ9B=Â=CÃ B=ÃCÃC(ÃC	ÃC(ÃC	ÃC(Ã(C,Ã/C,c           	      ó,  ‡— d„ Št          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          d¬¦  «        ˆfd„t	          d	¦  «        D ¦   «         ¦  «        }|D ]$}t          t          |¦  «        ¦  «        dk    sJ ‚Œ%	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          d¬¦  «        ˆfd
„t	          d	¦  «        D ¦   «         ¦  «        }|D ]$}t          t          |¦  «        ¦  «        dk    sJ ‚Œ%	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nc            	      ó   — t           t          d¬¦  «        d„ t          d¦  «        D ¦   «         ¦  «        ¦  «        } | t           t          d¬¦  «        d„ t          d¦  «        D ¦   «         ¦  «        ¦  «        z  } | S )Nr
   ©Ún_jobsc              3   óX   K  — | ]%} t          t          j        ¦  «        ¦   «         V — Œ&d S r   ©r   ÚosÚgetpidr_   s     r   rH   zOtest_nested_backend_context_manager.<locals>.get_nested_pids.<locals>.<genexpr>(  s5   è è € Ð%MÐ%M¸qÐ&8¥g­b¬iÑ&8Ô&8Ñ&:Ô&:Ð%MÐ%MÐ%MÐ%MÐ%MÐ%Mr!   c              3   óX   K  — | ]%} t          t          j        ¦  «        ¦   «         V — Œ&d S r   rô   r_   s     r   rH   zOtest_nested_backend_context_manager.<locals>.get_nested_pids.<locals>.<genexpr>)  s5   è è € Ð&NÐ&NÀÐ'9¥w­r¬yÑ'9Ô'9Ñ';Ô';Ð&NÐ&NÐ&NÐ&NÐ&NÐ&Nr!   )Úsetr   rR   )Úpidss    r   Úget_nested_pidsz<test_nested_backend_context_manager.<locals>.get_nested_pids'  s|   € ÝÐ%•8 1Ð%Ñ%Ô%Ð%MÐ%MÅEÈ!ÁHÄHÐ%MÑ%MÔ%MÑMÔMÑNÔNˆØ•Ð&•H AÐ&Ñ&Ô&Ð&NÐ&NÅUÈ1ÁXÄXÐ&NÑ&NÔ&NÑNÔNÑOÔOÑOˆØˆr!   r?   r@   r   rB   r
   rñ   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r   r^   ©r0   r`   rú   s     €r   rH   z6test_nested_backend_context_manager.<locals>.<genexpr>/  óG   øè è € ð 0ð 0àð -•G˜OÑ,Ô,Ñ.Ô.ð0ð 0ð 0ð 0ð 0ð 0r!   rJ   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r   r^   rü   s     €r   rH   z6test_nested_backend_context_manager.<locals>.<genexpr>9  rý   r!   )r   r   r   r   rR   r6   rø   )rÝ   rV   rW   rX   r8   Ú
pid_groupsÚ	pid_grouprú   s          @r   Ú#test_nested_backend_context_managerr  &  s'  ø€ ðð ð õ
 
‰Œð 4‘k�q™&˜1˜aÝ�A�i”L ~Ð6Ñ6Ô6ð 	4¸&Ý ¨Ð0Ñ0Ô0ð 4ð 4Ø/�X¨QÐ/Ñ/Ô/ð 0ð 0ð 0ð 0å" 2™YœYð0ñ 0ô 0ñ ô �
ð ",ð 4ð 4�IÝ�s 9™~œ~Ñ.Ô.°!Ò3Ð3Ð3Ð3Ð3ð4ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð	4ð 	4ð 	4ñ 	4ô 	4ð 	4ð 	4ð 	4ð 	4ð 	4ð 	4øøøð 	4ð 	4ð 	4ð 	4õ �A�i”L ~Ð6Ñ6Ô6ð 	4¸&Ý ¨Ð0Ñ0Ô0ð 4ð 4Ø/�X¨QÐ/Ñ/Ô/ð 0ð 0ð 0ð 0å" 2™YœYð0ñ 0ô 0ñ ô �
ð ",ð 4ð 4�IÝ�s 9™~œ~Ñ.Ô.°!Ò3Ð3Ð3Ð3Ð3ð4ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð	4ð 	4ð 	4ñ 	4ô 	4ð 	4ð 	4ð 	4ð 	4ð 	4ð 	4øøøð 	4ð 	4ð 	4ð 	4ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð 4ð 4s¢   “F	±C ÁAB)ÂC Â)B-Â-C Â0B-Â1C Â4F	Ã C	ÃF	ÃC	ÃF	Ã"E1Ã3AEÅE1ÅEÅE1Å!EÅ"E1Å%F	Å1E5	Å5F	Å8E5	Å9F	Æ	FÆFc           
      ó$  ‡	‡
— d„ Š	ˆ	fd„Š
t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5  t          ¦   «         5 } ‰	|¦  «        dk    sJ ‚|j        dk    sJ ‚ |ˆ
fd	„t          d
¦  «        D ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   |D ]\  }}|dk    sJ ‚|dk    sJ ‚Œ	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nc                 ó$   — | j         j        j        S r   )rc   Ú	__class__r¿   )Úps    r   Ú_backend_typezJtest_nested_backend_context_manager_implicit_n_jobs.<locals>._backend_typeE  s   € ØŒzÔ#Ô,Ð,r!   c                  óx   •— t          ¦   «         5 }  ‰| ¦  «        | j        fcd d d ¦  «         S # 1 swxY w Y   d S r   )r   rò   )r  r  s    €r   Úget_nested_implicit_n_jobszWtest_nested_backend_context_manager_implicit_n_jobs.<locals>.get_nested_implicit_n_jobsH  s‚   ø€ Ý‰ZŒZð 	.˜1Ø �= Ñ#Ô# Q¤XÐ-ð	.ð 	.ð 	.ð 	.ñ 	.ô 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.øøøð 	.ð 	.ð 	.ð 	.ð 	.ð 	.s   �/¯3¶3r?   r@   r   rB   r   éÿÿÿÿc              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r   r^   )r0   r`   r  s     €r   rH   zFtest_nested_backend_context_manager_implicit_n_jobs.<locals>.<genexpr>R  sH   øè è € ð *ð *àð <�Ð :Ñ;Ô;Ñ=Ô=ð*ð *ð *ð *ð *ð *r!   r
   )r   r   r   r   rò   rR   )rA   rV   rW   rX   r8   r  Úall_nested_n_jobsÚbackend_typeÚnested_n_jobsr  r  s            @@r   Ú3test_nested_backend_context_manager_implicit_n_jobsr  A  sw  øø€ ð-ð -ð -ð.ð .ð .ð .ð .õ 
‰Œð /‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	/°Ý ¨Ð0Ñ0Ô0ð 
/ð 
/Ý‘Z”Zð  1Ø(˜=¨Ñ+Ô+Ð/GÒGÐGÐGÐGØœ8 rš>˜>˜>˜>Ø()¨ð *ð *ð *ð *å!& q¡¤ð*ñ *ô *ñ )ô )Ð%ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð 4Eð /ð /Ñ/�L -Ø'Ð+CÒCÐCÐCÐCØ(¨BÒ.Ð.Ð.Ð.Ð.ð/ð
/ð 
/ð 
/ñ 
/ô 
/ð 
/ð 
/ð 
/ð 
/ð 
/ð 
/øøøð 
/ð 
/ð 
/ð 
/ð	/ð 	/ð 	/ñ 	/ô 	/ð 	/ð 	/ð 	/ð 	/ð 	/ð 	/øøøð 	/ð 	/ð 	/ð 	/ð/ð /ð /ñ /ô /ð /ð /ð /ð /ð /ð /ð /øøøð /ð /ð /ð /ð /ð /s}   ™D·C-ÁCÁAB&	ÂCÂ&B*Â*CÂ-B*Â.CÃ
C-ÃCÃC-ÃCÃC-Ã!DÃ-C1	Ã1DÃ4C1	Ã5DÄD	ÄD	c                 ó  — t          j        t          ¦  «        5 }t          d¬¦  «        5  	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   dt	          |j        ¦  «                             ¦   «         v sJ ‚d S )Nr   rB   zcreate a dask client)rS   rT   r$   r   ÚstrÚvalueÚlower)rA   Úinfos     r   Útest_errorsr  [  sú   € Ý	Œ•zÑ	"Ô	"ð  dÝ VÐ,Ñ,Ô,ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð "¥S¨¬¡_¤_×%:Ò%:Ñ%<Ô%<Ð<Ð<Ð<Ð<Ð<Ð<s.   šA«9­A¹=	½AÁ =	ÁAÁAÁAc           	      óÆ  — t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d¬¦  «        5   t          d¬¦  «        d„ t	          d¦  «        D ¦   «         ¦  «        }t          |d	         d	         d	         t          ¦  «        sJ ‚	 d d d ¦  «         n# 1 swxY w Y   t          d¬¦  «        5   t          d¬¦  «        d
„ t	          d¦  «        D ¦   «         ¦  «        }t          |d	         d	         d	         t          ¦  «        sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr?   r@   r   rB   r
   rñ   c              3   óR   K  — | ]"} t          t          ¦  «        d ¬¦  «        V — Œ#d S )N©Únested_require©r   Úouterr_   s     r   rH   z.test_correct_nested_backend.<locals>.<genexpr>h  sN   è è € ð ,Kð ,KØ<=�N•G�E‘N”N°$Ð7Ñ7Ô7ð,Kð ,Kð ,Kð ,Kð ,Kð ,Kr!   r/   r   c              3   óR   K  — | ]"} t          t          ¦  «        d ¬¦  «        V — Œ#dS )Ú	sharedmemr  Nr  r_   s     r   rH   z.test_correct_nested_backend.<locals>.<genexpr>n  sI   è è € ð ,'ð ,'àð #•G�E‘N”N°+Ð>Ñ>Ô>ð,'ð ,'ð ,'ð ,'ð ,'ð ,'r!   )r   r   r   r   rR   rd   r   r   )rA   rV   rW   rX   r8   Úresults         r   Útest_correct_nested_backendr  c  sÂ  € Ý	‰Œð E‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	E°å ¨Ð0Ñ0Ô0ð Kð KØ+�¨Ð+Ñ+Ô+ð ,Kð ,KÝAFÀqÁÄð,Kñ ,Kô ,Kñ Kô K�å! &¨¤)¨A¤,¨q¤/Õ3IÑJÔJÐJÐJÐJÐJðKð Kð Kñ Kô Kð Kð Kð Kð Kð Kð Køøøð Kð Kð Kð Kõ !¨Ð0Ñ0Ô0ð Eð EØ+�¨Ð+Ñ+Ô+ð ,'ð ,'å" 1™XœXð,'ñ ,'ô ,'ñ 'ô '�õ " &¨¤)¨A¤,¨q¤/Õ3CÑDÔDÐDÐDÐDÐDð	Eð Eð Eñ Eô Eð Eð Eð Eð Eð Eð Eøøøð Eð Eð Eð Eð	Eð 	Eð 	Eñ 	Eô 	Eð 	Eð 	Eð 	Eð 	Eð 	Eð 	Eøøøð 	Eð 	Eð 	Eð 	EðEð Eð Eñ Eô Eð Eð Eð Eð Eð Eð Eð Eøøøð Eð Eð Eð Eð Eð Es}   �E­D>¾AB%ÂD>Â%B)Â)D>Â,B)Â-D>Ã AD'ÄD>Ä'D+Ä+D>Ä.D+Ä/D>Ä2EÄ>E	ÅEÅE	ÅEÅEÅEc                 ój   ‡ —  t          dd¬¦  «        ˆ fd„t          d¦  «        D ¦   «         ¦  «        S )Nr
   Úthreads)rò   Úpreferc              3   óR   •K  — | ]!} t          t          ¦  «        ‰¦  «        V — Œ"d S r   )r   Úmiddle)r0   r`   r  s     €r   rH   zouter.<locals>.<genexpr>u  sD   øè è € ð 0ð 0Ø,-ˆ�•‰Œ˜Ñ'Ô'ð0ð 0ð 0ð 0ð 0ð 0r!   r/   ©r   rR   r  s   `r   r  r  t  sP   ø€ Ø/�8˜1 YÐ/Ñ/Ô/ð 0ð 0ð 0ð 0Ý16°q±´ð0ñ 0ô 0ñ ô ð r!   c                 ód   —  t          d| ¬¦  «        d„ t          d¦  «        D ¦   «         ¦  «        S )Nr
   )rò   Úrequirec              3   óN   K  — | ] } t          t          ¦  «        ¦   «         V — Œ!d S r   )r   Úinnerr_   s     r   rH   zmiddle.<locals>.<genexpr>{  sA   è è € ð /ð /Øˆ�•‰ŒÑÔð/ð /ð /ð /ð /ð /r!   r/   r$  )r&  s    r   r#  r#  z  sE   € Ø.�8˜1 gÐ.Ñ.Ô.ð /ð /Ý"'¨¡(¤(ð/ñ /ô /ñ ô ð r!   c                  ó(   — t          ¦   «         j        S r   )r   rc   r   r!   r   r(  r(  €  s   € Ý‰:Œ:ÔÐr!   c                 ó  — t          | dd¬¦  «        5  t          d¬¦  «        5   t          d¬¦  «        d„ t          d	¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )
NFT)rA   Ú	processesÚset_as_defaultr   rB   ru   rñ   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   )r   ÚidrF   s     r   rH   z0test_secede_with_no_processes.<locals>.<genexpr>ˆ  s0   è è € Ð@Ð@°!˜{�w¥r™{œ{¨1™~œ~Ð@Ð@Ð@Ð@Ð@Ð@r!   r
   )r   r   r   rR   r@   s    r   Útest_secede_with_no_processesr/  „  s6  € å	�T U¸4Ð	@Ñ	@Ô	@ð Að AÝ VÐ,Ñ,Ô,ð 	Að 	AØ�H˜AÐÑÔÐ@Ð@µu¸Q±x´xÐ@Ñ@Ô@Ñ@Ô@Ð@ð	Að 	Að 	Añ 	Aô 	Að 	Að 	Að 	Að 	Að 	Að 	Aøøøð 	Að 	Að 	Að 	AðAð Að Añ Aô Að Að Að Að Að Að Að Aøøøð Að Að Að Að Að As4   “A9¤1A!ÁA9Á!A%	Á%A9Á(A%	Á)A9Á9A=Â A=c                 ó,   — ddl m}  |¦   «         j        S )Nr   )Ú
get_worker)r   r1  r?   )r`   r1  s     r   Ú_worker_addressr2  ‹  s#   € Ø&Ð&Ð&Ð&Ð&Ð&Øˆ:‰<Œ<ÔÐr!   c           	      ó~  — t          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t          d|d         ¬¦  «        5   t          ¦   «         d„ t	          d¦  «        D ¦   «         ¦  «        }||d         gdz  k    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   t          d|d         ¬¦  «        5   t          ¦   «         d„ t	          d¦  «        D ¦   «         ¦  «        }||d         gdz  k    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr?   r@   r   )rC   Úworkersc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   ©r   r2  rF   s     r   rH   z-test_dask_backend_keywords.<locals>.<genexpr>”  óN   è è € ð !Dð !DØ45Ð,•G�OÑ,Ô,¨QÑ/Ô/ð!Dð !Dð !Dð !Dð !Dð !Dr!   rJ   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   r6  rF   s     r   rH   z-test_dask_backend_keywords.<locals>.<genexpr>™  r7  r!   rm   rU   s         r   Útest_dask_backend_keywordsr9  �  sr  € Ý	‰Œð 
2‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 		2°Ý ¨¸¸9¼ÐFÑFÔFð 2ð 2Ø •h‘j”jð !Dð !DÝ9>¸r¹¼ð!Dñ !Dô !Dñ Dô D�à˜q œ|˜n¨rÑ1Ò1Ð1Ð1Ð1Ð1ð2ð 2ð 2ñ 2ô 2ð 2ð 2ð 2ð 2ð 2ð 2øøøð 2ð 2ð 2ð 2õ
 !¨¸¸9¼ÐFÑFÔFð 2ð 2Ø •h‘j”jð !Dð !DÝ9>¸r¹¼ð!Dñ !Dô !Dñ Dô D�à˜q œ|˜n¨rÑ1Ò1Ð1Ð1Ð1Ð1ð2ð 2ð 2ñ 2ô 2ð 2ð 2ð 2ð 2ð 2ð 2øøøð 2ð 2ð 2ð 2ð		2ð 		2ð 		2ñ 		2ô 		2ð 		2ð 		2ð 		2ð 		2ð 		2ð 		2øøøð 		2ð 		2ð 		2ð 		2ð
2ð 
2ð 
2ñ 
2ô 
2ð 
2ð 
2ð 
2ð 
2ð 
2ð 
2ð 
2øøøð 
2ð 
2ð 
2ð 
2ð 
2ð 
2s~   �D2­DÁABÂDÂBÂDÂBÂDÂ5ADÃ7DÄDÄDÄ
DÄDÄD2ÄD	ÄD2Ä!D	Ä"D2Ä2D6Ä9D6c                 óÆ  — t          d| ¬¦  «        5 }t          d¬¦  «        5   t          ¦   «         d„ t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   t	          ¦   «         }|j        j        j        r7t          d¦  «         t	          ¦   «         |dz   k     sJ ‚|j        j        j        °7|j	        rJ ‚	 d d d ¦  «         d S # 1 swxY w Y   d S )	NF)r+  rA   r   rB   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   z/test_scheduler_tasks_cleanup.<locals>.<genexpr>¡  ó0   è è € Ð:Ð:¨1�|•w�s‘|”| A‘”Ð:Ð:Ð:Ð:Ð:Ð:r!   rJ   g{®Gáz„?rÊ   )
r   r   r   rR   r   r   Ú	schedulerrŠ   r	   Úfutures)rA   r8   Ústarts      r   Útest_scheduler_tasks_cleanupr@  ž  si  € Ý	˜% dÐ	+Ñ	+Ô	+ð 	"¨vÝ VÐ,Ñ,Ô,ð 	;ð 	;Ø�H‰JŒJÐ:Ð:µ°b±	´	Ð:Ñ:Ô:Ñ:Ô:Ð:ð	;ð 	;ð 	;ñ 	;ô 	;ð 	;ð 	;ð 	;ð 	;ð 	;ð 	;øøøð 	;ð 	;ð 	;ð 	;õ ‘”ˆØŒnÔ&Ô,ð 	&Ý�$‰KŒKˆKÝ‘6”6˜E A™IÒ%Ð%Ð%Ð%ð ŒnÔ&Ô,ð 	&ð ”>Ð!Ð!Ð!Ð!ð	"ð 	"ð 	"ñ 	"ô 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"øøøð 	"ð 	"ð 	"ð 	"ð 	"ð 	"s5   ’C£/AÁCÁA"	Á"CÁ%A"	Á&A"CÃCÃCÚcluster_strategyÚadaptiveÚlate_scalingz2.1.1z1.28.0z?distributed bug - https://github.com/dask/distributed/pull/2841)Úreasonc                 óê  — t          ddd¬¦  «        }t          |¦  «        }| dk    r |j        dd¬¦  «         n| dk    r |j        d¦  «         	 t	          d¬	¦  «        5   t          ¦   «         d
„ t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   |                     ¦   «           |j        ¦   «          d S # |                     ¦   «           |j        ¦   «          w xY w)Nr   Fr
   ©r›   r+  rœ   rB  )ÚminimumÚmaximumrC  r   rB   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   z(test_wait_for_workers.<locals>.<genexpr>¾  r<  r!   rJ   )r   r   ÚadaptÚscaler   r   rR   r®   )rA  r   r8   s      r   Útest_wait_for_workersrL  «  s?  € õ
  Q°%ÈAÐNÑNÔN€GÝ�G‰_Œ_€FØ˜:Ò%Ð%ØˆŒ˜a¨Ð+Ñ+Ô+Ð+Ð+Ø	˜^Ò	+Ð	+ð
 	ˆŒ�aÑÔÐðÝ VÐ,Ñ,Ô,ð 	;ð 	;ð �H‰JŒJÐ:Ð:µ°b±	´	Ð:Ñ:Ô:Ñ:Ô:Ð:ð	;ð 	;ð 	;ñ 	;ô 	;ð 	;ð 	;ð 	;ð 	;ð 	;ð 	;øøøð 	;ð 	;ð 	;ð 	;ð
 	�Š‰ŒˆØˆŒ‰Œˆˆˆøð 	�Š‰ŒˆØˆŒ‰Œˆˆøøøs0   ÁC Á"/BÂC ÂB!Â!C Â$B!Â%C Ã%C2c                  ó  — t          ddd¬¦  «        } t          | ¦  «        }	 t          dd¬¦  «        5  d}t          j        t
          |¬	¦  «        5   t          ¦   «         d
„ t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          dd¬¦  «        5  d}t          j        t          |¬	¦  «        5   t          ¦   «         d„ t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   | 	                    ¦   «           | j	        ¦   «          d S # | 	                    ¦   «           | j	        ¦   «          w xY w)Nr   Fr
   rF  r   gš™™™™™¹?)rC   Úwait_for_workers_timeoutz7DaskDistributedBackend has no worker after 0.1 seconds.)Úmatchc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   z0test_wait_for_workers_timeout.<locals>.<genexpr>Í  ó0   è è € Ð>Ð>¨q˜<�7¥3™<œ<¨™?œ?Ð>Ð>Ð>Ð>Ð>Ð>r!   rJ   z+DaskDistributedBackend has no active workerc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   z0test_wait_for_workers_timeout.<locals>.<genexpr>Ó  rQ  r!   )
r   r   r   rS   rT   ÚTimeoutErrorr   rR   ÚRuntimeErrorr®   )r   r8   Úmsgs      r   Útest_wait_for_workers_timeoutrV  Ä  sj  € å Q°%ÈAÐNÑNÔN€GÝ�G‰_Œ_€FðÝ VÀcÐJÑJÔJð 	?ð 	?àKˆCÝ”�|°3Ð7Ñ7Ô7ð ?ð ?Ø•‘
”
Ð>Ð>µE¸"±I´IÐ>Ñ>Ô>Ñ>Ô>Ð>ð?ð ?ð ?ñ ?ô ?ð ?ð ?ð ?ð ?ð ?ð ?øøøð ?ð ?ð ?ð ?ð	?ð 	?ð 	?ñ 	?ô 	?ð 	?ð 	?ð 	?ð 	?ð 	?ð 	?øøøð 	?ð 	?ð 	?ð 	?õ  VÀaÐHÑHÔHð 	?ð 	?à?ˆCÝ”�|°3Ð7Ñ7Ô7ð ?ð ?Ø•‘
”
Ð>Ð>µE¸"±I´IÐ>Ñ>Ô>Ñ>Ô>Ð>ð?ð ?ð ?ñ ?ô ?ð ?ð ?ð ?ð ?ð ?ð ?øøøð ?ð ?ð ?ð ?ð	?ð 	?ð 	?ñ 	?ô 	?ð 	?ð 	?ð 	?ð 	?ð 	?ð 	?øøøð 	?ð 	?ð 	?ð 	?ð 	�Š‰ŒˆØˆŒ‰Œˆˆˆøð 	�Š‰ŒˆØˆŒ‰Œˆˆøøøsš   £E  ´B$Á/BÂB$ÂB	ÂB$ÂB	ÂB$ÂE  Â$B(Â(E  Â+B(Â,E  Ã D0Ã/DÄD0ÄD	ÄD0Ä D	Ä!D0Ä$E  Ä0D4Ä4E  Ä7D4Ä8E  Å %FrC   ÚlokyÚmultiprocessingc                 óä  ‡ — t          d¬¦  «        }t          |¦  «        }	 ˆ fd„}|                     |¦  «        }|                     ¦   «         }t	          |¦  «        dk    sJ ‚|d         j        }t          |t          ¦  «        sJ ‚dt          |¦  «        v sJ ‚	 | 	                    d¬¦  «          |j	        d¬¦  «         d S # | 	                    d¬¦  «          |j	        d¬¦  «         w xY w)	Nr
   )r›   c                  óÄ   •— t          j        d¬¦  «        5 }  t          d‰¬¦  «        d„ t          d¦  «        D ¦   «         ¦  «         d d d ¦  «         n# 1 swxY w Y   | S )NT)Úrecordr
   )rò   rC   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r   rE   rF   s     r   rH   zftest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallel.<locals>.<genexpr>å  sA   è è € ð 48ð 48Ø()�L•G�C‘L”L ‘O”Oð48ð 48ð 48ð 48ð 48ð 48r!   rJ   )ÚwarningsÚcatch_warningsr   rR   )r[  rC   s    €r   Úfunc_using_joblib_parallelzStest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallelß  sµ   ø€ õ
 Ô(°Ð5Ñ5Ô5ð 8¸Ø3• ¨7Ð3Ñ3Ô3ð 48ð 48Ý-2°2©Y¬Yð48ñ 48ô 48ñ 8ô 8ð 8ð8ð 8ð 8ñ 8ô 8ð 8ð 8ð 8ð 8ð 8ð 8øøøð 8ð 8ð 8ð 8ð ˆMs   —2AÁAÁAr/   r   zdistributed.worker.daemonr§   r¨   )
r   r   Úsubmitr  r6   Úmessagerd   ÚUserWarningr  r®   )rC   r   r8   r_  Úfutr[  Úwarnings   `      r   Ú/test_joblib_warning_inside_dask_daemonic_workerre  Ù  s  ø€ å QÐ'Ñ'Ô'€GÝ�G‰_Œ_€Fð"ð		ð 		ð 		ð 		ð 		ð �mŠmÐ6Ñ7Ô7ˆØ—’‘”ˆå�6‰{Œ{˜aÒÐÐÐØ˜”)Ô#ˆÝ˜'¥;Ñ/Ô/Ð/Ð/Ð/Ø*­c°'©l¬lÐ:Ð:Ð:Ð:Ð:à�Š˜RˆÑ Ô Ð ØˆŒ˜bÐ!Ñ!Ô!Ð!Ð!Ð!øð 	�Š˜RˆÑ Ô Ð ØˆŒ˜bÐ!Ñ!Ô!Ð!Ð!øøøs   ¢A:C Ã)C/)r"   )r   r   )CÚ
__future__r   r   r   rõ   r]  rS   r   Úuuidr   r   r	   Ú r   r   r   re   r   r   Ú_daskr   rª   r   r   r   r   r   Údistributed.metricsÚdistributed.utils_testr   r   r   r    r'   r=   rZ   rh   rj   rp   ÚmarkÚparametrizerŒ   r²   Úobjectr´   rÇ   rÒ   rà   r7   rR   rî   r  r  r  r  r  r#  r(  r/  r2  r9  r@  ÚskipifÚ__version__rL  rV  re  r   r!   r   ú<module>rq     sñ  ðØ @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ø 	€	€	€	Ø €€€à €€€Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð à 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø :Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ø *Ð *Ð *Ð *Ð *Ð *à!ˆfÔ! -Ñ0Ô0€Ø€vÔ˜6Ñ"Ô"€ð 9Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ø $Ð $Ð $Ð $Ð $Ð $ð 9Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8ð	ð 	ð 	ð8ð 8ð 8ð 8ðð ð ð:ð :ð :ð>ð >ð >ð0ð ð ðð ð ð „×Ò˜ 4¨ -Ñ0Ô0ð@ð @ñ 1Ô0ð@ð26"ð 6"ð 6"ðr,ð ,ð ,ð ,ð ,�fñ ,ô ,ð ,ðð ð ð ðð ð ðJ-ð -ð -ð< „×Ò˜ T T¨%¨%°©(¬(¡^¤^Ñ4Ô4ðð ñ 5Ô4ðð:4ð 4ð 4ð6/ð /ð /ð4=ð =ð =ðEð Eð Eð"ð ð ðð ð ðð ð ðAð Að Að ð  ð  ð
2ð 2ð 2ð
"ð 
"ð 
"ð „×ÒÐ+¨j¸.Ð-IÑJÔJØ„×ÒØÔ˜wÒ&ÐN¨;Ô+BÀhÒ+NØLð ñ Nô Nðð ñNô Nñ KÔJðð*ð ð ð* „×Ò˜ VÐ->Ð$?Ñ@Ô@ð"ð "ñ AÔ@ð"ð "ð "r!   