§
    dŠtj”Y  ã                   ó”  — d dl mZmZm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ZddlmZmZmZmZ ddlmZ dd	lmZmZ d
dlmZmZ d
dlmZmZ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'  ej(        dd¬¦  «        d„ ¦   «         Z)d„ Z*dJd„Z+d„ Z,d„ Z-d„ Z.ej/         0                    dddg¦  «        ej/         0                    deeg¦  «        d„ ¦   «         ¦   «         Z1eej/         0                    dddg¦  «        ej/         0                    d d!d"g¦  «        ej/         0                    deeg¦  «        d#„ ¦   «         ¦   «         ¦   «         ¦   «         Z2eej/         0                    deeg¦  «        d$„ ¦   «         ¦   «         Z3d%„ Z4d&„ Z5ej/         0                    d'dd(g¦  «        d)„ ¦   «         Z6d*„ Z7 G d+„ d,e8¦  «        Z9dKd-„Z:d.„ Z;d/„ Z<ej/         0                    d0 e= e>d¦  «        ¦  «        ¦  «        d1„ ¦   «         Z?d2„ Z@d3„ ZAd4„ ZBd5„ ZCd6„ ZDd7„ ZEd8„ ZFd9„ ZGd:„ ZHd;„ ZId<„ ZJej/         0                    d=d>d?g¦  «        ej/         K                    ejL        d@k    o
ejL        dAk    dB¬C¦  «        dD„ ¦   «         ¦   «         ZMdE„ ZNej/         0                    dFdGdHg¦  «        dI„ ¦   «         ZOdS )Lé    )Úabsolute_importÚdivisionÚprint_functionN©Úrandom)Úsleep)Úuuid4é   )ÚParallelÚdelayedÚparallel_backendÚparallel_config)ÚDaskDistributedBackend)ÚAutoBatchingMixinÚThreadingBackendé   )ÚnpÚ
with_numpy)Ú_recursive_backend_infoÚ_test_deadlock_with_generatorÚ8_test_parallel_unordered_generator_returns_fastest_firstÚdistributedÚdask)ÚClientÚLocalClusterÚ
get_client)Útime)ÚcleanupÚclusterÚincÚfunctionT)ÚscopeÚautousec              #   óØ   K  — ddl m} d„ |j        D ¦   «         }d V — |                     ¦   «         D ]7\  }}|€!t          j                             |d ¦  «         Œ(|t          j        |<   Œ8d S )Nr   )ÚParallelBackendBasec                 óN   — i | ]"}|t           j                             |¦  «        “Œ#S © )ÚosÚenvironÚget)Ú.0Úks     úS/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/joblib/test/test_dask.pyú
<dictcomp>z(avoid_dask_env_leaks.<locals>.<dictcomp>(   s(   € ÐXÐXÐX¨!�•B”J—N’N 1Ñ%Ô%ÐXÐXÐXó    )Újoblib._parallel_backendsr%   ÚMAX_NUM_THREADS_VARSÚitemsr(   r)   Úpop)Útmp_pathr%   Ú	old_valuer,   Úvs        r-   Úavoid_dask_env_leaksr7   !   sŽ   è è € ð
 >Ð=Ð=Ð=Ð=Ð=àXÐXÐ/BÔ/WÐXÑXÔX€IØ	€E€E€Eð —’Ñ!Ô!ð ð ‰ˆˆ1Øˆ9ÝŒJ�NŠN˜1˜dÑ#Ô#Ð#Ð#à�BŒJ�q‰MˆMð	ð r/   c                  ó   — d S ©Nr'   )ÚargsÚkwargss     r-   Únoopr<   3   s   € Ø€Dr/   çš™™™™™©?c                 óF   — t          |¦  «         | rt          d¦  «        ‚d S )Nzcondition evaluated to True)r   Ú
ValueError)Ú	conditionÚdurations     r-   Úslow_raise_value_errorrB   7   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 r9   )Úlog)Údask_workers    r-   ú<lambda>zcount_events.<locals>.<lambda>>   s   € °;´?€ r/   c                 ó,   •— g | ]}|d          ‰k    ¯|‘ŒS ©r   r'   )r+   ÚeventÚ
event_names     €r-   ú
<listcomp>z count_events.<locals>.<listcomp>B   s'   ø€ ÐGÐGÐG�u°°a´¸JÒ0FÐ0FˆUÐ0FÐ0FÐ0Fr/   )Úrunr2   ÚlenÚlist)rK   ÚclientÚworker_eventsÚevent_countsÚwÚeventss   `     r-   Úcount_eventsrU   =   sv   ø€ Ø—J’JÐBÐBÑCÔC€MØ€LØ"×(Ò(Ñ*Ô*ð 
ð 
‰	ˆˆ6ÝØGÐGÐGÐG¥ V¡¤ÐGÑGÔGñ
ô 
ˆ�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 r9   ©r   r    ©r+   Úis     r-   ú	<genexpr>ztest_simple.<locals>.<genexpr>K   ó0   è è € Ð DÐ D°Q ¥­¡¤¨a¡¤Ð DÐ DÐ DÐ DÐ DÐ Dr/   é
   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r'   ©r    r^   s     r-   rL   ztest_simple.<locals>.<listcomp>L   ó   € Ð9Ð9Ð9¨!�s 1™vœvÐ9Ð9Ð9r/   c              3   óX   K  — | ]%} t          t          ¦  «        |d k    ¦  «        V — Œ&dS )é   N)r   rB   r^   s     r-   r`   ztest_simple.<locals>.<genexpr>O   sK   è è € ð ð ØDEÐ7�Õ 6Ñ7Ô7¸¸QºÑ?Ô?ðð ð ð ð ð r/   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   ztest_simple.<locals>.<genexpr>S   ra   r/   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r'   rd   r^   s     r-   rL   ztest_simple.<locals>.<listcomp>T   re   r/   )r   r   r   r   ÚrangeÚpytestÚraisesr?   ©rY   ÚsÚaÚbrP   Úseqs         r-   Útest_simplerr   G   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å”]¥:Ñ.Ô.ð ð Ø•H‘J”Jð ð ÝINÈrÉÌðñ ô ñ ô ð ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð
 !•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 )	NrW   rX   r   rZ   r   c              3   óF   K  — | ]} t          d „ ¦  «        ¦   «         V — ŒdS )c                  ó   — d S r9   r'   r'   r/   r-   rG   z?test_dask_backend_uses_autobatching.<locals>.<genexpr>.<lambda>j   s   € ¨T€ r/   N©r   ©r+   Ú_s     r-   r`   z6test_dask_backend_uses_autobatching.<locals>.<genexpr>j   s5   è è € ÐNÐN¸Ð2�W \ \Ñ2Ô2Ñ4Ô4ÐNÐNÐNÐNÐNÐNr/   ç     ˆÃ@rb   )r   Úcompute_batch_sizer   r   r   r   r   Ú_backendÚ
isinstanceÚparallelÚ_effective_batch_sizerj   Úint)rY   rn   ro   rp   rP   r}   r[   s          r-   Ú#test_dask_backend_uses_autobatchingr€   W   sO  € åÔ1ÝÔ/ð	0ð 	0ð 	0ð 	0õ 
‰Œð >‘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ÐNÐN½eÅCÈÁHÄH¹o¼oÐNÑNÔNÑNÔNÐNØ"Ô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Ún_jobséÿÿÿÿÚcontextc                 óÖ   — t                                dd¬¦  «        5   |d¦  «        5  t          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 ©Nr
   ©Ú	n_workersÚthreads_per_workerr   )r   r   r   )r�   rƒ   s     r-   ÚAtest_parallel_unordered_generator_returns_fastest_first_with_daskr‰   n   s  € õ 
×	Ò	 a¸AÐ	Ñ	>Ô	>ð Oð OÀÀÈÁÄð Oð OÝ@ÀÀvÑNÔNÐNðOð Oð Oñ Oô Oð Oð Oð Oð Oð Oð Oøøøð Oð Oð Oð Oð Oð Oð Oñ Oô Oð Oð Oð Oð Oð Oð Oð Oøøøð Oð Oð Oð Oð Oð Os3   �A©AºAÁA
	Á
AÁA
	ÁAÁA"Á%A"Ú	return_asÚ	generatorÚgenerator_unorderedc                 óØ   — t                                dd¬¦  «        5   | d¦  «        5  t          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 r…   )r   r   r   )rƒ   rŠ   r�   s      r-   Ú%test_deadlock_with_generator_and_daskrŽ   u   sõ   € õ
 
×	Ò	 a¸AÐ	Ñ	>Ô	>ð ?ð ?ÀÀÈÁÄð ?ð ?Ý% d¨I°vÑ>Ô>Ð>ð?ð ?ð ?ñ ?ô ?ð ?ð ?ð ?ð ?ð ?ð ?øøøð ?ð ?ð ?ð ?ð ?ð ?ð ?ñ ?ô ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?øøøð ?ð ?ð ?ð ?ð ?ð ?s3   �A©A»AÁA	ÁAÁA	ÁAÁA#Á&A#c                 óx  — t                                dd¬¦  «        5  t          j        t	          d¦  «        t          j        ¬¦  «        }t          d¦  «        D ]e} | d¦  «        5  t          |¬¦  «        }d d d ¦  «         n# 1 swxY w Y   t          |¦  «        dk    sJ ‚t          d„ |D ¦   «         ¦  «        sJ ‚Œf | d¦  «        5  t          ¦   «         }d d d ¦  «         n# 1 swxY w Y   t          |¦  «        dk    sJ ‚t          d	„ |D ¦   «         ¦  «        sJ ‚	 d d d ¦  «         d S # 1 swxY w Y   d S )
Nr
   r†   g    ÐcA©Údtyper   ©Údataé   c              3   ó(   K  — | ]\  }}|d k    V — ŒdS ©r   Nr'   ©r+   Únamerx   s      r-   r`   z4test_nested_parallelism_with_dask.<locals>.<genexpr>ˆ   s=   è è € ð ð Ù5<°T¸1�Ð0Ò0ðð ð ð ð ð r/   c              3   ó(   K  — | ]\  }}|d k    V — ŒdS r–   r'   r—   s      r-   r`   z4test_nested_parallelism_with_dask.<locals>.<genexpr>�   s=   è è € ð 
ð 
Ù18°°qˆDÐ,Ò,ð
ð 
ð 
ð 
ð 
ð 
r/   )
r   r   r   Úonesr   Úuint8rj   r   rN   Úall)rƒ   r“   r_   Úbackend_types_and_levelss       r-   Ú!test_nested_parallelism_with_daskrž   ~   sg  € õ 
×	Ò	 a¸AÐ	Ñ	>Ô	>ð 
ð 
åŒw•s˜3‘x”x¥r¤xÐ0Ñ0Ô0ˆÝ�q‘”ð 	ð 	ˆAØ�˜‘”ð Nð NÝ+BÈÐ+MÑ+MÔ+MÐ(ðNð Nð Nñ Nô Nð Nð Nð Nð Nð Nð Nøøøð Nð Nð Nð NåÐ/Ñ0Ô0°AÒ5Ð5Ð5Ð5Ýð ð Ø@Xðñ ô ñ ô ð ð ð ð ð
 ˆW�V‰_Œ_ð 	Að 	AÝ'>Ñ'@Ô'@Ð$ð	Að 	Að 	Añ 	Aô 	Að 	Að 	Að 	Að 	Að 	Að 	Aøøøð 	Að 	Að 	Að 	AåÐ+Ñ,Ô,°Ò1Ð1Ð1Ð1Ýð 
ð 
Ø<Tð
ñ 
ô 
ñ 
ô 
ð 	
ð 	
ð 
ð 	
ð
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
øøøð 
ð 
ð 
ð 
ð 
ð 
sZ   �A
D/Á'BÁ8D/ÂBÂD/ÂBÂ?D/ÃC&ÃD/Ã&C*	Ã*D/Ã-C*	Ã.3D/Ä/D3Ä6D3c                  ó   — t          ¦   «         S r9   r   r'   r/   r-   Úrandom2r    •   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 )NrW   rX   r   rZ   c              3   óN   K  — | ] } t          t          ¦  «        ¦   «         V — Œ!d S r9   )r   r    r^   s     r-   r`   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   rj   )rY   rn   ro   rp   rP   ÚxÚys          r-   Ú test_dont_assume_function_purityr¦   ™   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ÚmixedFc                 ó�  — 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'   r]   r^   s     r-   rL   z&test_dask_funcname.<locals>.<listcomp>¦   s&   € Ð3Ð3Ð3 Q�•�‘”˜a‘”Ð3Ð3Ð3r/   r”   Úbatch_of_inc_4_callsc                 óŒ   — g | ]A}|d z  r t          t          ¦  «        |¦  «        n t          t          ¦  «        |¦  «        ‘ŒBS )r
   )r   Úabsr    r^   s     r-   rL   z&test_dask_funcname.<locals>.<listcomp>©   sA   € ÐQÐQÐQÀ1 A¨¡EÐ>�•�‘”˜a‘”�¨|­wµs©|¬|¸A©¬ÐQÐQÐQr/   Úmixed_batch_of_inc_4_callsrW   rX   r   rZ   r
   rœ   )Ú
batch_sizeÚpre_dispatchc                 ó*   — t          | j        ¦  «        S r9   )rO   Útransition_log)Údask_schedulers    r-   Úfztest_dask_funcname.<locals>.f³   s   € Ý˜NÔ9Ñ:Ô:Ð:r/   Ú4Ú2c              3   ó*   K  — | ]}d |d         v V — ŒdS )Úbatch_of_incr   Nr'   )r+   Útups     r-   r`   z%test_dask_funcname.<locals>.<genexpr>¸   s+   è è € Ð?Ð?°C�~¨¨Q¬Ð/Ð?Ð?Ð?Ð?Ð?Ð?r/   )Újoblib._daskr©   rj   Úreprr   r   r   r   ÚreplaceÚrun_on_schedulerrœ   )rY   r§   r©   ÚtasksÚ
batch_reprrn   ro   rp   rP   rx   r´   rE   s               r-   Útest_dask_funcnamerÀ   ¡   sl  € à"Ð"Ð"Ð"Ð"Ð"àð 2Ø3Ð3­%°©(¬(Ð3Ñ3Ô3ˆØ+ˆ
ˆ
àQÐQÍÈaÉÌÐQÑQÔQˆØ1ˆ
å���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                  óL  ‡‡‡— d„ t          d¦  «        D ¦   «         } t          j        d¦  «        Š ‰j        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'   rw   s     r-   rL   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>Æ   s   € Ð$Ð$Ð$�AˆRÐ$Ð$Ð$r/   éd   Únumpyg    €„.Ac                 óŽ   •— |�‰j                              |‰¦  «         |                      t          ¦   «         j        ¦  «         | S r9   )ÚtestingÚassert_array_equalÚappendr	   Úhex)Úlist_r“   ÚXr   s     €€r-   Úisolated_operationzCtest_no_undesired_distributed_cache_hit.<locals>.isolated_operationÊ   s>   ø€ ØÐØŒJ×)Ò)¨$°Ñ2Ô2Ð2Ø�Š•U‘W”W”[Ñ!Ô!Ð!Øˆr/   r   r
   r†   r   rZ   c              3   óH   •K  — | ]} t          ‰¦  «        |¦  «        V — Œd S r9   rv   )r+   rÊ   rÌ   s     €r-   r`   z:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>Õ   s7   øè è € ÐSÐSÀEÐ8�WÐ%7Ñ8Ô8¸Ñ?Ô?ÐSÐSÐSÐSÐSÐSr/   c                 ó   — g | ]}g ‘ŒS r'   r'   rw   s     r-   rL   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 rI   ©rN   ©r+   Úrs     r-   rL   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’   Nrv   )r+   rÊ   rË   rÌ   s     €€r-   r`   z:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>å   sM   øè è € ð ð Ø?DÐ+•Ð*Ñ+Ô+¨E¸Ð:Ñ:Ô:ðð ð ð ð ð r/   c                 ó4   — g | ]}t          |¦  «        d k    ‘ŒS rI   rÑ   rÒ   s     r-   rL   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>ì   rÔ   r/   é   ©Útimeoutr9   )rj   rk   ÚimportorskipÚaranger   r   r   r   r   rU   ÚsumÚvaluesrœ   Úclose)Úlistsr   rP   ÚresÚcountsrË   rÌ   r   s        @@@r-   Ú'test_no_undesired_distributed_cache_hitrâ   »   s  øøø€ ð %Ð$�˜s™œÐ$Ñ$Ô$€EÝ	Ô	˜WÑ	%Ô	%€BØˆŒ	•#�c‘(”(ÑÔ€Aðð ð ð ð ð ð õ  Q¸1Ð=Ñ=Ô=€GÝ�G‰_Œ_€Fð"Ý VÐ,Ñ,Ô,ð 	Tð 	Tà•(‘*”*ÐSÐSÐSÐSÈUÐSÑSÔSÑSÔSˆCð	Tð 	Tð 	Tñ 	Tô 	Tð 	Tð 	Tð 	Tð 	Tð 	Tð 	Tøøøð 	Tð 	Tð 	Tð 	Tð Ð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   Á6G: Â$B6Â*G: Â6B:Â:G: Â=B:Â>BG: Å%E3Å'G: Å3E7Å7G: Å:E7Å;AG: Ç:)H#c                   ó$   — e Zd Zd„ Zd„ ZeZd„ ZdS )ÚCountSerializedc                 ó"   — || _         d| _        d S )Nr   )r¤   Úcount)Úselfr¤   s     r-   Ú__init__zCountSerialized.__init__ó   s   € ØˆŒØˆŒ
ˆ
ˆ
r/   c                 ó4   — | j         t          |d|¦  «        z   S )Nr¤   )r¤   Ú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ä   r¤   )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 r9   r'   )ro   rp   ÚcÚdÚes        r-   Úadd5r÷     s   € Øˆq‰5�1‰9�q‰=˜1ÑÐr/   c           
      ó  ‡‡‡‡‡‡— d„ t          d¦  «        D ¦   «         \  }ŠŠŠt          t          ¦  «        Šˆˆˆˆfd„t          d¦  «        D ¦   «         }| ‰‰‰‰dd¬¦  «         ‰‰‰‰‰d¬¦  «         ‰‰‰‰‰‰¬¦  «        gz  }d„ |D ¦   «         }t          ¦   «         5 \  }}t	          |d         | ¬	¦  «        5 Št          d
|‰‰g¬¦  «        5   t          d¬¦  «        |¦  «        }||k    sJ ‚	 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   |j
        }‰j
        |k    sJ ‚‰j
        |k    sJ ‚‰j
        }|‰‰‰fD ]	}	d|	_
        Œ
t          ¦   «         5 \  }}t	          |d         | ¬	¦  «        5 Št          ¦   «         Š|‰‰fD ])}
‰                     |
d¬¦  «        ‰t          |
¦  «        <   Œ*ˆˆf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   |j
        }‰j
        |k    sJ ‚‰j
        |k    sJ ‚||k    sJ ‚t          d„ t          j                             d¦  «        D ¦   «         ¦  «        }|dk     r‰j
        |dz   k    sJ ‚d S ‰j
        |k    sJ ‚d S )Nc              3   ó4   K  — | ]}t          |¦  «        V — Œd S r9   )rä   r^   s     r-   r`   z&test_manual_scatter.<locals>.<genexpr>  s*   è è € Ð7Ð7¨•/ !Ñ$Ô$Ð7Ð7Ð7Ð7Ð7Ð7r/   r”   c           	      ó0   •— g | ]} ‰‰‰‰d d¬¦  «        ‘ŒS )r”   é   ©rõ   rö   r'   )r+   rx   r´   r¤   r¥   Úzs     €€€€r-   rL   z'test_manual_scatter.<locals>.<listcomp>  s.   ø€ Ð5Ð5Ð5 aˆQˆQˆq�!�Q˜!˜qÐ!Ñ!Ô!Ð5Ð5Ð5r/   rb   rû   rü   c                 ó&   — g | ]\  }}} ||i |¤Ž‘ŒS r'   r'   )r+   Úfuncr:   r;   s       r-   rL   z'test_manual_scatter.<locals>.<listcomp>  s.   € ÐFÐFÐFÑ*<¨$°°f���dÐ%˜fÐ%Ð%ÐFÐFÐFr/   rW   rX   r   )r[   Úscatterr   )r¯   )r[   rY   r   r   T)Ú	broadcastc                 ó  •— g | ]}\  }}} ‰j         |gˆfd „|D ¦   «         ¢R i t          ˆfd„|                     ¦   «         D ¦   «         ¦  «        ¤dt          t	          ¦   «         ¦  «        i¤Ž                     ¦   «         ‘Œ~S )c              3   ó^   •K  — | ]'}‰                      t          |¦  «        |¦  «        V — Œ(d S r9   ©r*   Úid)r+   ÚargÚ	scattereds     €r-   r`   z1test_manual_scatter.<locals>.<listcomp>.<genexpr>:  s7   øè è € ÐBÐB°c�i—m’m¥B s¡G¤G¨SÑ1Ô1ÐBÐBÐBÐBÐBÐBr/   c              3   óh   •K  — | ],\  }}|‰                      t          |¦  «        |¦  «        fV — Œ-d S r9   r  )r+   ÚkeyÚvaluer  s      €r-   r`   z1test_manual_scatter.<locals>.<listcomp>.<genexpr>;  sT   øè è € ð ð á(˜S %ð ˜iŸmšm­B¨u©I¬I°uÑ=Ô=Ð>ðð ð ð ð ð r/   r	  )ÚsubmitÚdictr2   Ústrr	   Úresult)r+   rÿ   r:   r;   rP   r  s       €€r-   rL   z'test_manual_scatter.<locals>.<listcomp>7  sÓ   ø€ ð ð ð ñ )�T˜4 ð �”ØðàBÐBÐBÐB¸TÐBÑBÔBðð ð õ ð ð ð ð à,2¯LªL©N¬Nðñ ô ñ ô ðð õ �E™GœG™œðð ð ÷ ’&‘(”(ðð ð r/   c              3   ó4   K  — | ]}t          |¦  «        V — Œd S r9   )r   )r+   r6   s     r-   r`   z&test_manual_scatter.<locals>.<genexpr>M  s(   è è € ÐSÐS¨1¥ A¡¤ÐSÐSÐSÐSÐSÐSr/   ú.)iç  r”   )rj   r   r÷   r   r   r   r   rk   rl   Ú	TypeErrorræ   r  r   r  Útupler   Ú__version__Úsplit)rY   rS   r¾   Úexpectedrn   rx   Úresults_parallelÚ%n_serialization_scatter_with_parallelÚn_serialization_with_parallelÚvarÚobjÚresults_nativeÚn_serialization_scatter_nativeÚdistributed_versionrP   r´   r  r¤   r¥   rý   s                 @@@@@@r-   Útest_manual_scatterr    sj  øøøøøø€ ð 8Ð7­e°A©h¬hÐ7Ñ7Ô7�J€A€qˆ!ˆQå•‰Œ€AØ5Ð5Ð5Ð5Ð5Ð5Ð5­5°©9¬9Ð5Ñ5Ô5€EØ	Ø	ˆˆ!ˆQ��Q˜!ÐÑÔØ	ˆˆ!ˆQ��Q˜!ÐÑÔØ	ˆˆ!ˆQ��Q˜!ÐÑÔðñ €Eð
 GÐFÀÐFÑFÔF€Hå	‰Œð 
‘f�q˜!Ý�A�i”L tÐ,Ñ,Ô,ð 		°Ý ¨¸!¸QÀ¸ÐCÑCÔCð 4ð 4Ø#9¥8°qÐ#9Ñ#9Ô#9¸%Ñ#@Ô#@Ð Ø'¨8Ò3Ð3Ð3Ð3Ð3ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4õ ”�yÑ)Ô)ð ð Ý$¨V¸$ÈÐJÑJÔJð ð Øðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð		ð 		ð 		ñ 		ô 		ð 		ð 		ð 		ð 		ð 		ð 		øøøð 		ð 		ð 		ð 		ð
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
øøøð 
ð 
ð 
ð 
ð -.¬GÐ)ØŒ7Ð;Ò;Ð;Ð;Ð;ØŒ7Ð;Ò;Ð;Ð;Ð;Ø$%¤GÐ!ð �1�a˜ˆ|ð ð ˆØˆŒ	ˆ	å	‰Œð .‘f�q˜!Ý�A�i”L tÐ,Ñ,Ô,ð 	.°Ý™œˆIØ˜!˜Q�wð Ið I�Ø%+§^¢^°CÀ4 ^Ñ%HÔ%H�	�"˜S™'œ'Ñ"Ð"ðð ð ð ð ð -2ðñ ô ˆNð " XÒ-Ð-Ð-Ð-Ð-ð!	.ð 	.ð 	.ñ 	.ô 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.øøøð 	.ð 	.ð 	.ð 	.ð.ð .ð .ñ .ô .ð .ð .ð .ð .ð .ð .øøøð .ð .ð .ð .ð* &'¤WÐ"ØŒ7Ð4Ò4Ð4Ð4Ð4ØŒ7Ð4Ò4Ð4Ð4Ð4à0Ð4RÒRÐRÐRÐRåÐSÐSµÔ0G×0MÒ0MÈcÑ0RÔ0RÐSÑSÔSÑSÔSÐØ˜YÒ&Ð&ð
 ŒwÐ7¸!Ñ;Ò;Ð;Ð;Ð;Ð;Ð;àŒwÐ7Ò7Ð7Ð7Ð7Ð7Ð7sÙ   Â#FÂ>E5Ã"DÃ6E5ÄDÄE5Ä	DÄ
E5Ä&EÄ9E	Ä;EÅEÅEÅEÅEÅE5ÅE"Å"E5Å%E"Å&E5Å)FÅ5E9	Å9FÅ<E9	Å=FÆFÆFÇI1Ç8AIÉI1ÉI	ÉI1É!I	É"I1É1I5É8I5c           	      ó~  ‡	— t          j        d¦  «        } |j        t          d¦  «        |j        ¬¦  «        Š	 |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Ä   ry   r�   rg   rW   rX   r   rZ   c              3   ó^   K  — | ](\  }} t          t          ¦  «        ||||¬ ¦  «        V — Œ)dS ))ÚoptN©r   r<   )r+   r_   r“   s      r-   r`   z$test_auto_scatter.<locals>.<genexpr>f  sS   è è € ð ð á˜˜4ð "•G�D‘M”M $¨¨a°TÐ:Ñ:Ô:ðð ð ð ð ð r/   rÏ   r
   c              3   ód   •K  — | ]*} t          t          ¦  «        ‰d d…         |¦  «        V — Œ+d S )Nrg   r"  )r+   r_   Údata1s     €r-   r`   z$test_auto_scatter.<locals>.<genexpr>s  s=   øè è € ÐIÐI¸1˜=�7¥4™=œ=¨¨r°¨r¬°AÑ6Ô6ÐIÐIÐIÐIÐIÐIr/   rû   r   )rk   rÚ   rš   r   r›   r   r   r   r   Ú	enumeraterU   rj   )
Úloop_in_threadr   Údata2Údata_to_processrn   ro   rp   rP   rá   r$  s
            @r-   Útest_auto_scatterr)  [  s   ø€ Ý	Ô	˜WÑ	%Ô	%€BØˆBŒG•C˜‘H”H B¤HÐ-Ñ-Ô-€EØˆBŒG•C˜‘H”H B¤HÐ-Ñ-Ô-€EØ�w ‘{¨ w°¡{Ñ3€Oå	‰Œð D‘k�q™&˜1˜aÝ�A�i”L ~Ð6Ñ6Ô6ð 	D¸&Ý ¨Ð0Ñ0Ô0ð ð ð •‘
”
ð ð å#,¨_Ñ#=Ô#=ðñ ô ñ ô ð ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ "Ð"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´   Á9EÂD.Â(/C#ÃD.Ã#C'Ã'D.Ã*C'Ã+6D.Ä"EÄ.D2	Ä2EÄ5D2	Ä6EÅE	ÅE	ÅH2Å<HÆ1G
Æ>HÇ
GÇHÇGÇ;HÈH2ÈH	ÈH2È!H	È"H2È2H6È9H6Úretry_noc           	      óà  ‡‡‡	‡
‡— t          j        d¦  «        Š
dŠd}ˆ
fd„Š	ˆˆ	fd„Št          ¦   «         5 \  }\  }}t          |d         | ¬¦  «        5 }t	          d¬¦  «        5   ‰
j        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Ä   rb   c                 ó$   •—  ‰j         | ¦  «        S r9   )rÜ   )r¤   r_   Újr   s      €r-   Úmy_sumz#test_nested_scatter.<locals>.my_sum‚  s   ø€ ØˆrŒ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   rZ   c              3   ó\   •K  — | ]&} t          ‰¦  «        ‰|d …         ‰|¦  «        V — Œ'd S r9   rv   )r+   r-  Úarrayr_   r.  s     €€€r-   r`   zEtest_nested_scatter.<locals>.outer_function_joblib.<locals>.<genexpr>ˆ  sP   øè è € ð !ð !Ø56�•˜‘”  a b b¤	¨1¨aÑ0Ô0ð!ð !ð !ð !ð !ð !r/   )r   r   r   rj   rÜ   )r1  r_   rP   ÚresultsÚNUM_INNER_TASKSr.  s   ``  €€r-   Úouter_function_joblibz2test_nested_scatter.<locals>.outer_function_joblib…  sÏ   øøø€ Ý‘”ˆÝ VÐ,Ñ,Ô,ð 	ð 	Ø •h‘j”jð !ð !ð !ð !ð !ð !Ý:?ÀÑ:PÔ:Pð!ñ !ô !ñ ô ˆGð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ �7‰|Œ|Ðs   ¢3A!Á!A%Á(A%rW   rX   r   rZ   i'  c              3   óZ   •K  — | ]%} t          ‰¦  «        ‰|d …         |¦  «        V — Œ&d S r9   rv   )r+   r_   Úmy_arrayr4  s     €€r-   r`   z&test_nested_scatter.<locals>.<genexpr>‘  sT   øè è € ð ð àð 3•GÐ1Ñ2Ô2°8¸A¸B¸B´<ÀÑCÔCðð ð ð ð ð r/   )rk   rÚ   r   r   r   rš   r   rj   )rY   r*  ÚNUM_OUTER_TASKSrn   ro   rp   rx   r3  r6  r.  r   r4  s          @@@@@r-   Útest_nested_scatterr8  {  só  øøøøø€ å	Ô	˜WÑ	%Ô	%€Bà€OØ€Oðð ð ð ð ðð ð ð ð ð õ 
‰Œð ‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	°Ý ¨Ð0Ñ0Ô0ð ð Ø"˜2œ7 5™>œ>�Ø•H‘J”Jð ð ð ð ð å" ?Ñ3Ô3ðñ ô ñ ô �ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sZ   ·C#ÁCÁ&AB4Â(CÂ4B8Â8CÂ;B8Â<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
   ©r�   c              3   óX   K  — | ]%} t          t          j        ¦  «        ¦   «         V — Œ&d S r9   ©r   r(   Úgetpidrw   s     r-   r`   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 r9   r=  rw   s     r-   r`   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   rj   )Ú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/   rW   rX   r   rZ   r
   r;  c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rv   ©r+   rx   rB  s     €r-   r`   z6test_nested_backend_context_manager.<locals>.<genexpr>   óE   øè è € ð 0ð 0Ø34Ð,•G˜OÑ,Ô,Ñ.Ô.ð0ð 0ð 0ð 0ð 0ð 0r/   rb   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rv   rD  s     €r-   r`   z6test_nested_backend_context_manager.<locals>.<genexpr>©  rE  r/   )r   r   r   r   rj   rN   r@  )r&  rn   ro   rp   rP   Ú
pid_groupsÚ	pid_grouprB  s          @r-   Ú#test_nested_backend_context_managerrI  —  s'  ø€ ðð ð õ
 
‰Œð 4‘k�q™&˜1˜aÝ�A�i”L ~Ð6Ñ6Ô6ð 	4¸&Ý ¨Ð0Ñ0Ô0ð 4ð 4Ø/�X¨QÐ/Ñ/Ô/ð 0ð 0ð 0ð 0Ý8=¸b¹	¼	ð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Ý8=¸b¹	¼	ð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 r9   )r{   Ú	__class__rï   )Úps    r-   Ú_backend_typezJtest_nested_backend_context_manager_implicit_n_jobs.<locals>._backend_type´  s   € ØŒzÔ#Ô,Ð,r/   c                  óx   •— t          ¦   «         5 }  ‰| ¦  «        | j        fcd d d ¦  «         S # 1 swxY w Y   d S r9   )r   r�   )rM  rN  s    €r-   Úget_nested_implicit_n_jobszWtest_nested_backend_context_manager_implicit_n_jobs.<locals>.get_nested_implicit_n_jobs·  s‚   ø€ Ý‰ZŒZð 	.˜1Ø �= Ñ#Ô# Q¤XÐ-ð	.ð 	.ð 	.ð 	.ñ 	.ô 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.øøøð 	.ð 	.ð 	.ð 	.ð 	.ð 	.s   �/¯3¶3rW   rX   r   rZ   r   r‚   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rv   )r+   rx   rP  s     €r-   r`   zFtest_nested_backend_context_manager_implicit_n_jobs.<locals>.<genexpr>Á  sF   øè è € ð *ð *ØBCÐ;�Ð :Ñ;Ô;Ñ=Ô=ð*ð *ð *ð *ð *ð *r/   r
   )r   r   r   r   r�   rj   )rY   rn   ro   rp   rP   rM  Úall_nested_n_jobsÚbackend_typeÚnested_n_jobsrN  rP  s            @@r-   Ú3test_nested_backend_context_manager_implicit_n_jobsrU  °  sw  øø€ ð-ð -ð -ð.ð .ð .ð .ð .õ 
‰Œð /‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 
	/°Ý ¨Ð0Ñ0Ô0ð 	/ð 	/Ý‘Z”Zð  1Ø(˜=¨Ñ+Ô+Ð/GÒGÐGÐGÐGØœ8 rš>˜>˜>˜>Ø()¨ð *ð *ð *ð *ÝGLÈQÁxÄxð*ñ *ô *ñ )ô )Ð%ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð 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   rZ   zcreate a dask client)rk   rl   r?   r   r  r
  Úlower)rY   Úinfos     r-   Útest_errorsrY  É  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 )NrW   rX   r   rZ   r
   r;  c              3   óR   K  — | ]"} t          t          ¦  «        d ¬¦  «        V — Œ#d S )N©Únested_require©r   Úouterrw   s     r-   r`   z.test_correct_nested_backend.<locals>.<genexpr>Ö  sF   è è € ð ,ð ,Ø<=�N•G�E‘N”N°$Ð7Ñ7Ô7ð,ð ,ð ,ð ,ð ,ð ,r/   r   r   c              3   óR   K  — | ]"} t          t          ¦  «        d ¬¦  «        V — Œ#dS )Ú	sharedmemr\  Nr^  rw   s     r-   r`   z.test_correct_nested_backend.<locals>.<genexpr>Ý  sF   è è € ð ,ð ,ØCD�N•G�E‘N”N°+Ð>Ñ>Ô>ð,ð ,ð ,ð ,ð ,ð ,r/   )r   r   r   r   rj   r|   r   r   )rY   rn   ro   rp   rP   r  s         r-   Útest_correct_nested_backendrb  Ñ  s½  € Ý	‰Œð E‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	E°å ¨Ð0Ñ0Ô0ð Kð KØ+�¨Ð+Ñ+Ô+ð ,ð ,ÝAFÀqÁÄð,ñ ,ô ,ñ ô �õ " &¨¤)¨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Ø+�¨Ð+Ñ+Ô+ð ,ð ,ÝHMÈaÉÌð,ñ ,ô ,ñ ô �õ " &¨¤)¨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 r9   )r   Úmiddle)r+   rx   r]  s     €r-   r`   zouter.<locals>.<genexpr>ä  sD   øè è € ð 0ð 0Ø,-ˆ�•‰Œ˜Ñ'Ô'ð0ð 0ð 0ð 0ð 0ð 0r/   r   ©r   rj   r\  s   `r-   r_  r_  ã  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 r9   )r   Úinnerrw   s     r-   r`   zmiddle.<locals>.<genexpr>ê  s0   è è € Ð.RÐ.RÀA¨~­wµu©~¬~Ñ/?Ô/?Ð.RÐ.RÐ.RÐ.RÐ.RÐ.Rr/   r   rh  )rj  s    r-   rg  rg  é  s4   € Ø.�8˜1 gÐ.Ñ.Ô.Ð.RÐ.RÍÈqÉÌÐ.RÑ.RÔ.RÑRÔRÐRr/   c                  ó(   — t          ¦   «         j        S r9   )r   r{   r'   r/   r-   rl  rl  í  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)rY   Ú	processesÚset_as_defaultr   rZ   r”   r;  c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   )r   r  r^   s     r-   r`   z0test_secede_with_no_processes.<locals>.<genexpr>õ  s0   è è € Ð@Ð@°!˜{�w¥r™{œ{¨1™~œ~Ð@Ð@Ð@Ð@Ð@Ð@r/   r
   )r   r   r   rj   rX   s    r-   Útest_secede_with_no_processesrr  ñ  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   rt  rW   )rx   rt  s     r-   Ú_worker_addressru  ø  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 )NrW   rX   r   )r[   Úworkersc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   ©r   ru  r^   s     r-   r`   z-test_dask_backend_keywords.<locals>.<genexpr>  ó5   è è € Ð PÐ PÀÐ!9¥­Ñ!9Ô!9¸!Ñ!<Ô!<Ð PÐ PÐ PÐ PÐ PÐ Pr/   rb   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   ry  r^   s     r-   r`   z-test_dask_backend_keywords.<locals>.<genexpr>  rz  r/   r£   rm   s         r-   Útest_dask_backend_keywordsr|  þ  sF  € Ý	‰Œð 2‘k�q™&˜1˜aÝ�A�i”L tÐ,Ñ,Ô,ð 	2°Ý ¨¸¸9¼ÐFÑFÔFð 2ð 2Ø •h‘j”jÐ PÐ PÅeÈBÁiÄiÐ PÑ PÔ PÑPÔP�Ø˜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Ð PÐ PÅeÈBÁiÄiÐ PÑ PÔ PÑPÔP�Ø˜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)ro  rY   r   rZ   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   z/test_scheduler_tasks_cleanup.<locals>.<genexpr>  ó0   è è € Ð:Ð:¨1�|•w�s‘|”| A‘”Ð:Ð:Ð:Ð:Ð:Ð:r/   rb   g{®Gáz„?rû   )
r   r   r   rj   r   r   Ú	schedulerr¾   r   Úfutures)rY   rP   Ú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‡   ro  rˆ   r…  )ÚminimumÚmaximumr†  r   rZ   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   z(test_wait_for_workers.<locals>.<genexpr>+  r  r/   rb   )r   r   ÚadaptÚscaler   r   rj   rÞ   )r„  r   rP   s      r-   Útest_wait_for_workersr�    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
   r‰  r   gš™™™™™¹?)r[   Úwait_for_workers_timeoutz7DaskDistributedBackend has no worker after 0.1 seconds.)Úmatchc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   z0test_wait_for_workers_timeout.<locals>.<genexpr>:  ó0   è è € Ð>Ð>¨q˜<�7¥3™<œ<¨™?œ?Ð>Ð>Ð>Ð>Ð>Ð>r/   rb   z+DaskDistributedBackend has no active workerc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   z0test_wait_for_workers_timeout.<locals>.<genexpr>@  r”  r/   )
r   r   r   rk   rl   ÚTimeoutErrorr   rj   ÚRuntimeErrorrÞ   )r   rP   Úmsgs      r-   Útest_wait_for_workers_timeoutr™  1  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r[   Ú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�   r[   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r]   r^   s     r-   r`   zftest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallel.<locals>.<genexpr>R  s0   è è € Ð3WÐ3WÈ°LµG½C±L´LÀ±O´OÐ3WÐ3WÐ3WÐ3WÐ3WÐ3Wr/   rb   )ÚwarningsÚcatch_warningsr   rj   )rž  r[   s    €r-   Úfunc_using_joblib_parallelzStest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallelL  sµ   ø€ õ
 Ô(°Ð5Ñ5Ô5ð X¸Ø3• ¨7Ð3Ñ3Ô3Ð3WÐ3WÍUÐSUÉYÌYÐ3WÑ3WÔ3WÑWÔWÐWðXð Xð Xñ Xô Xð Xð Xð Xð Xð Xð Xøøøð Xð Xð Xð Xð ˆMs   —2AÁAÁAr   r   zdistributed.worker.daemonr×   rØ   )
r   r   r  r  rN   Úmessager|   ÚUserWarningr  rÞ   )r[   r   rP   r¢  Úfutrž  Úwarnings   `      r-   Ú/test_joblib_warning_inside_dask_daemonic_workerr§  F  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   )PÚ
__future__r   r   r   r(   r   r   r   r   Úuuidr	   rk   Ú r   r   r   r   Ú_daskr   r}   r   r   Úcommonr   r   Útest_parallelr   r   r   rÚ   r   r   r   r   r   Údistributed.metricsÚdistributed.utils_testr   r   r    Úfixturer7   r<   rB   rU   rr   r€   ÚmarkÚparametrizer‰   rŽ   rž   r    r¦   rÀ   râ   Úobjecträ   r÷   r  r)  rO   rj   r8  rI  rU  rY  rb  r_  rg  rl  rr  ru  r|  rƒ  Úskipifr  r�  r™  r§  r'   r/   r-   ú<module>rµ     s�  ðØ @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ð @à 	€	€	€	Ø €€€Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð à €€€à CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ CØ *Ð *Ð *Ð *Ð *Ð *Ø :Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ø "Ð "Ð "Ð "Ð "Ð "Ð "Ð "ðð ð ð ð ð ð ð ð ð ð "ˆ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ð €„�j¨$Ð/Ñ/Ô/ðð ñ 0Ô/ðð"	ð 	ð 	ð8ð 8ð 8ð 8ðð ð ð:ð :ð :ð >ð >ð >ð. „×Ò˜ A r 7Ñ+Ô+Ø„×Ò˜ _Ð6FÐ$GÑHÔHðOð Oñ IÔHñ ,Ô+ðOð
 Ø„×Ò˜ A r 7Ñ+Ô+Ø„×Ò˜ {Ð4IÐ&JÑKÔKØ„×Ò˜ _Ð6FÐ$GÑHÔHð?ð ?ñ IÔHñ LÔKñ ,Ô+ñ „ð?ð
 Ø„×Ò˜ _Ð6FÐ$GÑHÔHð
ð 
ñ IÔHñ „ð
ð*ð ð ðð ð ð „×Ò˜ 4¨ -Ñ0Ô0ð@ð @ñ 1Ô0ð@ð24"ð 4"ð 4"ðn,ð ,ð ,ð ,ð ,�fñ ,ô ,ð ,ðð ð ð ðP8ð P8ð P8ðl-ð -ð -ð@ „×Ò˜ T T¨%¨%°©(¬(¡^¤^Ñ4Ô4ðð ñ 5Ô4ðð64ð 4ð 4ð2/ð /ð /ð2=ð =ð =ðEð Eð Eð$ð ð ðSð Sð Sðð ð ðAð Að Að ð  ð  ð	2ð 	2ð 	2ð
"ð 
"ð 
"ð „×ÒÐ+¨j¸.Ð-IÑJÔJØ„×ÒØÔ˜wÒ&ÐN¨;Ô+BÀhÒ+NØLð ñ ô ðð ñ	ô ñ KÔJð
ð*ð ð ð* „×Ò˜ VÐ->Ð$?Ñ@Ô@ð"ð "ñ AÔ@ð"ð "ð "r/   