§
    Øj1Z  ã                   ó¬  — 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(        j)        Z* ej+        dd¬¦  «        d„ ¦   «         Z,d„ Z-dJd„Z.d„ Z/d„ Z0d„ Z1ej(         2                    dddg¦  «        ej(         2                    deeg¦  «        d„ ¦   «         ¦   «         Z3eej(         2                    dddg¦  «        ej(         2                    d d!d"g¦  «        ej(         2                    deeg¦  «        d#„ ¦   «         ¦   «         ¦   «         ¦   «         Z4eej(         2                    deeg¦  «        d$„ ¦   «         ¦   «         Z5d%„ Z6d&„ Z7ej(         2                    d'dd(g¦  «        d)„ ¦   «         Z8d*„ Z9 G d+„ d,e:¦  «        Z;dKd-„Z<d.„ Z=d/„ Z>ej(         2                    d0 e? e@d¦  «        ¦  «        ¦  «        d1„ ¦   «         ZAd2„ ZBd3„ ZCd4„ ZDd5„ ZEd6„ ZFd7„ ZGd8„ ZHd9„ ZId:„ ZJd;„ ZKd<„ ZLej(         2                    d=d>d?g¦  «        ej(         M                    ejN        d@k    o
ejN        dAk    dB¬C¦  «        dD„ ¦   «         ¦   «         ZOdE„ ZPej(         2                    dFdGdHg¦  «        dI„ ¦   «         ZQd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     úŠ/Users/tedpeters/Documents/Projects/Claude Projects/Misc Tools/notename-sheets/.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<   7   s   € Ø€Dr/   çš™™™™™©?c                 óF   — t          |¦  «         | rt          d¦  «        ‚d S )Nzcondition evaluated to True)r   Ú
ValueError)Ú	conditionÚdurations     r-   Úslow_raise_value_errorrB   ;   s.   € Ý	ˆ(�O„O€OØð 8ÝÐ6Ñ7Ô7Ð7ð8ð 8r/   c                 ó8   ‡ — ˆ fd„}|                      |¦  «        S )Nc                 ó¾   •— d}| j         j                             ¦   «         D ]:}| j                              |¦  «        }|t	          ˆfd„|D ¦   «         ¦  «        z  }Œ;|S )Nr   c                 ó,   •— g | ]}|d          ‰k    ¯|‘ŒS ©r   r'   )r+   ÚeventÚ
event_names     €r-   ú
<listcomp>z.count_events.<locals>.work.<locals>.<listcomp>F   s'   ø€ ÐRÐRÐR E¸5À¼8ÀzÒ;QÐ;Q˜%Ð;QÐ;QÐ;Qr/   )ÚstateÚtasksÚvaluesÚstoryÚlen)Údask_workerÚcountÚ
task_stateÚ
task_storyrH   s       €r-   Úworkzcount_events.<locals>.workB   so   ø€ ØˆØ%Ô+Ô1×8Ò8Ñ:Ô:ð 	Tð 	TˆJØ$Ô*×0Ò0°Ñ<Ô<ˆJØ•SÐRÐRÐRÐR¨ZÐRÑRÔRÑSÔSÑSˆEˆEØˆr/   )Úrun)rH   ÚclientrS   s   `  r-   Úcount_eventsrV   A   s0   ø€ ðð ð ð ð ð �:Š:�dÑÔÐ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>P   ó0   è è € Ð DÐ D°Q ¥­¡¤¨a¡¤Ð DÐ DÐ DÐ DÐ DÐ Dr/   é
   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r'   ©r    r_   s     r-   rI   ztest_simple.<locals>.<listcomp>Q   ó   € Ð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-   ra   ztest_simple.<locals>.<genexpr>T   sK   è è € ð ð ØDEÐ7�Õ 6Ñ7Ô7¸¸QºÑ?Ô?ðð ð ð ð ð r/   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r^   r_   s     r-   ra   ztest_simple.<locals>.<genexpr>X   rb   r/   c                 ó,   — g | ]}t          |¦  «        ‘ŒS r'   re   r_   s     r-   rI   ztest_simple.<locals>.<listcomp>Y   rf   r/   )r   r   r   r   ÚrangeÚpytestÚraisesr?   ©rZ   ÚsÚaÚbrU   Úseqs         r-   Útest_simplers   L   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 )	NrX   rY   r   r[   r   c              3   óF   K  — | ]} t          d „ ¦  «        ¦   «         V — ŒdS )c                  ó   — d S r9   r'   r'   r/   r-   ú<lambda>z?test_dask_backend_uses_autobatching.<locals>.<genexpr>.<lambda>o   s   € ¨T€ r/   N©r   ©r+   Ú_s     r-   ra   z6test_dask_backend_uses_autobatching.<locals>.<genexpr>o   s5   è è € ÐNÐN¸Ð2�W \ \Ñ2Ô2Ñ4Ô4ÐNÐNÐNÐNÐNÐNr/   ç     ˆÃ@rc   )r   Úcompute_batch_sizer   r   r   r   r   Ú_backendÚ
isinstanceÚparallelÚ_effective_batch_sizerk   Úint)rZ   ro   rp   rq   rU   r   r\   s          r-   Ú#test_dask_backend_uses_autobatchingr‚   \   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‹   s   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�   z   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+   Únamerz   s      r-   ra   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-   ra   z4test_nested_parallelism_with_dask.<locals>.<genexpr>•   s=   è è € ð 
ð 
Ù18°°qˆDÐ,Ò,ð
ð 
ð 
ð 
ð 
ð 
r/   )
r   r   r   Úonesr�   Úuint8rk   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 )NrX   rY   r   r[   c              3   óN   K  — | ] } t          t          ¦  «        ¦   «         V — Œ!d S r9   )r   r¢   r_   s     r-   ra   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   rk   )rZ   ro   rp   rq   rU   Ú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-   rI   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-   rI   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_callsrX   rY   r   r[   r
   rž   )Ú
batch_sizeÚpre_dispatchc                 ó*   — t          | j        ¦  «        S r9   )ÚlistÚ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-   ra   z%test_dask_funcname.<locals>.<genexpr>½   s+   è è € Ð?Ð?°C�~¨¨Q¬Ð/Ð?Ð?Ð?Ð?Ð?Ð?r/   )Újoblib._daskr«   rk   Úreprr   r   r   r   ÚreplaceÚrun_on_schedulerrž   )rZ   r©   r«   rK   Ú
batch_reprro   rp   rq   rU   rz   r·   Úlogs               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'   ry   s     r-   rI   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   r[   c              3   óH   •K  — | ]} t          ‰¦  «        |¦  «        V — Œd S r9   rx   )r+   rÍ   rÏ   s     €r-   ra   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'   ry   s     r-   rI   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 rF   ©rN   ©r+   Úrs     r-   rI   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”   Nrx   )r+   rÍ   rÎ   rÏ   s     €€r-   ra   z:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>ê   sM   øè è € ð ð Ø?DÐ+•Ð*Ñ+Ô+¨E¸Ð:Ñ:Ô:ðð ð ð ð ð r/   c                 ó4   — g | ]}t          |¦  «        d k    ‘ŒS rF   rÔ   rÕ   s     r-   rI   z;test_no_undesired_distributed_cache_hit.<locals>.<listcomp>ñ   r×   r/   é   ©Útimeoutr9   )rk   rl   ÚimportorskipÚaranger�   r   r   r   r   rV   ÚsumrL   rž   Úclose)Úlistsr   rU   Ú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¦   rP   )Ú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   )rP   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'   )rp   rq   Ú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-   ra   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+   rz   r·   r¦   r§   Úzs     €€€€r-   rI   z'test_manual_scatter.<locals>.<listcomp>  s.   ø€ Ð5Ð5Ð5 aˆQˆQˆq�!�Q˜!˜qÐ!Ñ!Ô!Ð5Ð5Ð5r/   rc   rü   rý   c                 ó&   — g | ]\  }}} ||i |¤Ž‘ŒS r'   r'   )r+   Úfuncr:   r;   s       r-   rI   z'test_manual_scatter.<locals>.<listcomp>  s.   € ÐFÐFÐFÑ*<¨$°°f���dÐ%˜fÐ%Ð%ÐFÐFÐFr/   rX   rY   r   )r\   Úscatterr   )r±   )r\   rZ   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-   ra   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-   ra   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;   rU   r  s       €€r-   rI   z'test_manual_scatter.<locals>.<listcomp><  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-   ra   z&test_manual_scatter.<locals>.<genexpr>R  s(   è è € ÐSÐS¨1¥ A¡¤ÐSÐSÐSÐSÐSÐSr/   ú.)iç  r–   )rk   r   rø   r   r   r   r   rl   rm   Ú	TypeErrorrP   r  r  r  Útupler   Ú__version__Úsplit)rZ   ÚwrK   Úexpectedro   rz   Úresults_parallelÚ%n_serialization_scatter_with_parallelÚn_serialization_with_parallelÚvarÚobjÚresults_nativeÚn_serialization_scatter_nativeÚdistributed_versionrU   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Ç   r{   r’   rh   rX   rY   r   r[   c              3   ó^   K  — | ](\  }} t          t          ¦  «        ||||¬ ¦  «        V — Œ)dS ))ÚoptN©r   r<   )r+   r`   r•   s      r-   ra   z$test_auto_scatter.<locals>.<genexpr>k  sS   è è € ð ð á˜˜4ð "•G�D‘M”M $¨¨a°TÐ:Ñ:Ô:ðð ð ð ð ð r/   rÒ   r
   c              3   ód   •K  — | ]*} t          t          ¦  «        ‰d d…         |¦  «        V — Œ+d S )Nrh   r$  )r+   r`   Údata1s     €r-   ra   z$test_auto_scatter.<locals>.<genexpr>x  s=   øè è € ÐIÐI¸1˜=�7¥4™=œ=¨¨r°¨r¬°AÑ6Ô6ÐIÐIÐIÐIÐIÐIr/   rü   r   )rl   rÝ   rœ   r�   r�   r   r   r   r   Ú	enumeraterV   rk   )
Úloop_in_threadr   Údata2Údata_to_processro   rp   rq   rU   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Ç   rc   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   r[   c              3   ó\   •K  — | ]&} t          ‰¦  «        ‰|d …         ‰|¦  «        V — Œ'd S r9   rx   )r+   r/  Úarrayr`   r0  s     €€€r-   ra   zEtest_nested_scatter.<locals>.outer_function_joblib.<locals>.<genexpr>�  sP   øè è € ð !ð !Ø56�•˜‘”  a b b¤	¨1¨aÑ0Ô0ð!ð !ð !ð !ð !ð !r/   )r   r   r   rk   rß   )r3  r`   rU   ÚresultsÚNUM_INNER_TASKSr0  s   ``  €€r-   Úouter_function_joblibz2test_nested_scatter.<locals>.outer_function_joblibŠ  sÏ   øøø€ Ý‘”ˆÝ VÐ,Ñ,Ô,ð 	ð 	Ø •h‘j”jð !ð !ð !ð !ð !ð !Ý:?ÀÑ:PÔ:Pð!ñ !ô !ñ ô ˆGð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ �7‰|Œ|Ðs   ¢3A!Á!A%Á(A%rX   rY   r   r[   i'  c              3   óZ   •K  — | ]%} t          ‰¦  «        ‰|d …         |¦  «        V — Œ&d S r9   rx   )r+   r`   Úmy_arrayr6  s     €€r-   ra   z&test_nested_scatter.<locals>.<genexpr>–  sT   øè è € ð ð àð 3•GÐ1Ñ2Ô2°8¸A¸B¸B´<ÀÑCÔCðð ð ð ð ð r/   )rl   rÝ   r   r   r   rœ   r   rk   )rZ   r,  ÚNUM_OUTER_TASKSro   rp   rq   rz   r5  r8  r0  r   r6  s          @@@@@r-   Útest_nested_scatterr:  €  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(   Úgetpidry   s     r-   ra   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?  ry   s     r-   ra   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   rk   )Ú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/   rX   rY   r   r[   r
   r=  c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rx   ©r+   rz   rD  s     €r-   ra   z6test_nested_backend_context_manager.<locals>.<genexpr>¥  óE   øè è € ð 0ð 0Ø34Ð,•G˜OÑ,Ô,Ñ.Ô.ð0ð 0ð 0ð 0ð 0ð 0r/   rc   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rx   rF  s     €r-   ra   z6test_nested_backend_context_manager.<locals>.<genexpr>®  rG  r/   )r   r   r   r   rk   rN   rB  )r(  ro   rp   rq   rU   Ú
pid_groupsÚ	pid_grouprD  s          @r-   Ú#test_nested_backend_context_managerrK  œ  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ƒ   )rO  rP  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rX   rY   r   r[   r   r„   c              3   óF   •K  — | ]} t          ‰¦  «        ¦   «         V — Œd S r9   rx   )r+   rz   rR  s     €r-   ra   zFtest_nested_backend_context_manager_implicit_n_jobs.<locals>.<genexpr>Æ  sF   øè è € ð *ð *ØBCÐ;�Ð :Ñ;Ô;Ñ=Ô=ð*ð *ð *ð *ð *ð *r/   r
   )r   r   r   r   rƒ   rk   )rZ   ro   rp   rq   rU   rO  Úall_nested_n_jobsÚbackend_typeÚnested_n_jobsrP  rR  s            @@r-   Ú3test_nested_backend_context_manager_implicit_n_jobsrW  µ  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   r[   zcreate a dask client)rl   rm   r?   r   r  r  Úlower)rZ   Ú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 )NrX   rY   r   r[   r
   r=  c              3   óR   K  — | ]"} t          t          ¦  «        d ¬¦  «        V — Œ#d S )N©Únested_require©r   Úouterry   s     r-   ra   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`  ry   s     r-   ra   z.test_correct_nested_backend.<locals>.<genexpr>â  sF   è è € ð ,ð ,ØCD�N•G�E‘N”N°+Ð>Ñ>Ô>ð,ð ,ð ,ð ,ð ,ð ,r/   )r   r   r   r   rk   r~   r   r   )rZ   ro   rp   rq   rU   r  s         r-   Útest_correct_nested_backendrd  Ö  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+   rz   r_  s     €r-   ra   zouter.<locals>.<genexpr>é  sD   øè è € ð 0ð 0Ø,-ˆ�•‰Œ˜Ñ'Ô'ð0ð 0ð 0ð 0ð 0ð 0r/   r   ©r   rk   r^  s   `r-   ra  ra  è  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   Úinnerry   s     r-   ra   zmiddle.<locals>.<genexpr>ï  s0   è è € Ð.RÐ.RÀA¨~­wµu©~¬~Ñ/?Ô/?Ð.RÐ.RÐ.RÐ.RÐ.RÐ.Rr/   r   rj  )rl  s    r-   ri  ri  î  s4   € Ø.�8˜1 gÐ.Ñ.Ô.Ð.RÐ.RÍÈqÉÌÐ.RÑ.RÔ.RÑRÔRÐRr/   c                  ó(   — t          ¦   «         j        S r9   )r   r}   r'   r/   r-   rn  rn  ò  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)rZ   Ú	processesÚset_as_defaultr   r[   r–   r=  c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   )r   r  r_   s     r-   ra   z0test_secede_with_no_processes.<locals>.<genexpr>ú  s0   è è € Ð@Ð@°!˜{�w¥r™{œ{¨1™~œ~Ð@Ð@Ð@Ð@Ð@Ð@r/   r
   )r   r   r   rk   rY   s    r-   Útest_secede_with_no_processesrt  ö  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   rv  rX   )rz   rv  s     r-   Ú_worker_addressrw  ý  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 )NrX   rY   r   )r\   Úworkersc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   ©r   rw  r_   s     r-   ra   z-test_dask_backend_keywords.<locals>.<genexpr>  ó5   è è € Ð PÐ PÀÐ!9¥­Ñ!9Ô!9¸!Ñ!<Ô!<Ð PÐ PÐ PÐ PÐ PÐ Pr/   rc   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r{  r_   s     r-   ra   z-test_dask_backend_keywords.<locals>.<genexpr>  r|  r/   r¥   rn   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)rq  rZ   r   r[   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r^   r_   s     r-   ra   z/test_scheduler_tasks_cleanup.<locals>.<genexpr>  ó0   è è € Ð:Ð:¨1�|•w�s‘|”| A‘”Ð:Ð:Ð:Ð:Ð:Ð:r/   rc   g{®Gáz„?rü   )
r   r   r   rk   r   r   Ú	schedulerrK   r   Úfutures)rZ   rU   Ú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‰   rq  rŠ   r‡  )ÚminimumÚmaximumrˆ  r   r[   c              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r^   r_   s     r-   ra   z(test_wait_for_workers.<locals>.<genexpr>0  r�  r/   rc   )r   r   ÚadaptÚscaler   r   rk   rà   )r†  r   rU   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-   ra   z0test_wait_for_workers_timeout.<locals>.<genexpr>?  ó0   è è € Ð>Ð>¨q˜<�7¥3™<œ<¨™?œ?Ð>Ð>Ð>Ð>Ð>Ð>r/   rc   z+DaskDistributedBackend has no active workerc              3   óP   K  — | ]!} t          t          ¦  «        |¦  «        V — Œ"d S r9   r^   r_   s     r-   ra   z0test_wait_for_workers_timeout.<locals>.<genexpr>E  r–  r/   )
r   r   r   rl   rm   ÚTimeoutErrorr   rk   ÚRuntimeErrorrà   )r   rU   Úmsgs      r-   Útest_wait_for_workers_timeoutr›  6  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-   ra   zftest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallel.<locals>.<genexpr>W  s0   è è € Ð3WÐ3WÈ°LµG½C±L´LÀ±O´OÐ3WÐ3WÐ3WÐ3WÐ3WÐ3Wr/   rc   )ÚwarningsÚcatch_warningsr   rk   )r   r\   s    €r-   Úfunc_using_joblib_parallelzStest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallelQ  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   rU   r¤  Úfutr   Úwarnings   `      r-   Ú/test_joblib_warning_inside_dask_daemonic_workerr©  K  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   )RÚ
__future__r   r   r   r(   r¢  r   r   r   Úuuidr	   rl   Ú 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    ÚmarkÚthread_unsafeÚ
pytestmarkÚfixturer7   r<   rB   rV   rs   r‚   Úparametrizer‹   r�   r    r¢   r¨   rÃ   rä   Úobjectræ   rø   r   r+  r´   rk   r:  rK  rW  r[  rd  ra  ri  rn  rt  rw  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/   