ó
    oñ:i”Y  ã                   ód  • S SK JrJrJr  S SKrS SKrS SKJr  S SKJr  S SK	J
r
  S SKrSSKJrJrJrJr  SSKJr  SS	KJrJr  S
SKJrJr  S
SKJrJrJr  \R:                  " S5      r\R:                  " S5      rS SKJ r J!r!J"r"  S SK#Jr  S SK$J%r%J&r&J'r'  \RP                  " SSS9S 5       r)S r*SIS jr+S r,S r-S r.\R^                  Ra                  SSS/5      \R^                  Ra                  S\\/5      S 5       5       r1\\R^                  Ra                  SSS/5      \R^                  Ra                  SS S!/5      \R^                  Ra                  S\\/5      S" 5       5       5       5       r2\\R^                  Ra                  S\\/5      S# 5       5       r3S$ r4S% r5\R^                  Ra                  S&SS'/5      S( 5       r6S) r7 " S* S+\85      r9SJS, jr:S- r;S. r<\R^                  Ra                  S/\=" \>" S5      5      5      S0 5       r?S1 r@S2 rAS3 rBS4 rCS5 rDS6 rES7 rFS8 rGS9 rHS: rIS; rJ\R^                  Ra                  S<S=S>/5      \R^                  R—                  \R˜                  S?:*  =(       a    \R˜                  S@:¬  SASB9SC 5       5       rMSD rN\R^                  Ra                  SESFSG/5      SH 5       rOg)Ké    )Ú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              #   ó>  #   • SSK Jn  UR                   Vs0 s H"  o"[        R                  R                  U5      _M$     nnS v •  UR                  5        H=  u  p$Uc"  [        R                  R                  US 5        M*  U[        R                  U'   M?     g s  snf 7f)Nr   )ÚParallelBackendBase)Újoblib._parallel_backendsr%   ÚMAX_NUM_THREADS_VARSÚosÚenvironÚgetÚitemsÚpop)Útmp_pathr%   ÚkÚ	old_valueÚvs        ÚX/srv/projetos/modelo_ml_acdoc/venv/lib/python3.13/site-packages/joblib/test/test_dask.pyÚavoid_dask_env_leaksr2   !   sx   é € õ
 >à/B×/WÒ/WÓXÒ/W¨!”B—J‘J—N‘N 1Ó%Ò%Ñ/W€IÐXÛ	ð —‘Ö!‰ˆØ‰9Ü�J‰J�N‰N˜1˜dÖ#àŒB�J‰J�q‹Mò	 "ùò	 Yùs   ‚B—)BÁ ABc                  ó   • g ©N© )ÚargsÚkwargss     r1   Únoopr8   3   s   € Øó    c                 ó>   • [        U5        U (       a  [        S5      eg )Nzcondition evaluated to True)r   Ú
ValueError)Ú	conditionÚdurations     r1   Úslow_raise_value_errorr>   7   s   € Ü	ˆ(„OÞÜÐ6Ó7Ð7ð r9   c                 óÌ   • UR                  S 5      n0 nUR                  5        H6  u  pE[        [        U5       Vs/ s H  ofS   U :X  d  M  UPM     sn5      X4'   M8     U$ s  snf )Nc                 ó   • U R                   $ r4   )Úlog)Údask_workers    r1   Ú<lambda>Úcount_events.<locals>.<lambda>>   s   € °;·?²?r9   r   )Úrunr+   ÚlenÚlist)Ú
event_nameÚclientÚworker_eventsÚevent_countsÚwÚeventsÚevents          r1   Úcount_eventsrO   =   sd   € Ø—J‘JÑBÓC€MØ€LØ"×(Ñ(Ö*‰	ˆÜÜ $ V¤ÓG¢�u°a±¸JÑ0F�U¡ÑGó
ˆ‹ñ +ð Ðùò Hs   ¼A!
ÁA!
c           
      óÔ  • [        5        u  nu  p#[        US   U S9 n[        SS9   [        5       " S [	        S5       5       5      nU[	        S5       Vs/ s H  n[        U5      PM     sn:X  d   e[        R                  " [        5         [        5       " S [	        S5       5       5        S S S 5        [        5       " S [	        S5       5       5      nU[	        S5       Vs/ s H  n[        U5      PM     sn:X  d   e S S S 5        S S S 5        S S S 5        g s  snf ! , (       d  f       Nx= fs  snf ! , (       d  f       N:= f! , (       d  f       NC= f! , (       d  f       g = f)	NÚaddress©Úloopr   ©Úbackendc              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   ©r   r    ©Ú.0Úis     r1   Ú	<genexpr>Útest_simple.<locals>.<genexpr>K   ó   é € Ð Dº)°Q¤¬¤¨a§ º)ùó   ‚"$é
   c              3   óR   #   • U  H  n[        [        5      " US :H  5      v •  M     g7f)é   N)r   r>   rX   s     r1   r[   r\   O   s%   é € ð ÚIRÀAœÔ 6Ô7¸¸Q¹×?Ð?Êùs   ‚%'c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   r\   S   r]   r^   )	r   r   r   r   Úranger    ÚpytestÚraisesr;   )rS   ÚsÚaÚbrI   ÚseqrZ   s          r1   Útest_simplerj   G   s  € Ü	Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0Ü”jÑ D¼%À¼)Ó DÓD�Ø¬u°R¬yÓ9ªy¨!œs 1žv©yÑ9Ó9Ð9Ð9ä—]’]¤:Õ.Ü”Jñ ÜINÈrÌóô ÷ /ô
 ”jÑ D¼%À¼)Ó DÓD�Ø¬u°R¬yÓ9ªy¨!œs 1žv©yÑ9Ó9Ð9Ñ9÷ 1÷ -÷ 
ˆùò :ç.Õ.üò :÷ 1Õ0ú÷ -Õ,ú÷ 
�úso   ‹Ež
E¨/D7ÁDÁ,"D7Â!D!	Â/6D7Ã%D2Ã:D7ÄEÄEÄD7Ä!
D/Ä+D7Ä7
EÅEÅ
E	ÅEÅ
E'c                 ól  • [         R                  [        R                  L d   e[        5        u  nu  p#[	        US   U S9 n[        SS9   [        5        nUR                  n[        U[         5      (       d   eUR                  UL d   eUR                  S:X  d   eU" S [        [        S5      5       5       5        UR                  S:”  d   e S S S 5        S S S 5        S S S 5        S S S 5        g ! , (       d  f       N'= f! , (       d  f       N0= f! , (       d  f       N9= f! , (       d  f       g = f)	NrQ   rR   r   rT   r   c              3   óD   #   • U  H  n[        S  5      " 5       v •  M     g7f)c                  ó   • g r4   r5   r5   r9   r1   rC   Ú?test_dask_backend_uses_autobatching.<locals>.<genexpr>.<lambda>j   s   € ¨Tr9   N©r   ©rY   Ú_s     r1   r[   Ú6test_dask_backend_uses_autobatching.<locals>.<genexpr>j   s   é € ÐNºo¸œW¡\Ô2×4Ð4ºoùs   ‚ ç     ˆÃ@r_   )r   Úcompute_batch_sizer   r   r   r   r   Ú_backendÚ
isinstanceÚparallelÚ_effective_batch_sizerc   Úint)rS   rf   rg   rh   rI   rw   rU   s          r1   Ú#test_dask_backend_uses_autobatchingrz   W   sþ   € ä×1Ñ1Ü×/Ñ/ò	0ðð	0ô 
Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0Ü”Z 8ð '×/Ñ/�GÜ% gÔ/E×FÑFÐFÐFØ"×+Ñ+¨xÒ7Ð7Ð7Ø"×8Ñ8¸AÓ=Ð=Ð=ñ ÑN¼eÄCÈÃH¼oÓNÔNØ"×8Ñ8¸2Ó=Ð=Ñ=÷  ÷ 1÷ -÷ 
ˆ÷  •Zú÷ 1Õ0ú÷ -Õ,ú÷ 
�úsT   ®D%Á
DÁDÁA:C2	ÃDÃDÃ!D%Ã2
D Ã<DÄ
DÄDÄ
D"	ÄD%Ä%
D3Ún_jobséÿÿÿÿÚcontextc                 ó¼   • [         R                  SSS9   U" S5         [        S U 5        S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       g = f©Nr
   ©Ú	n_workersÚthreads_per_workerr   )r   r   r   )r{   r}   s     r1   ÚAtest_parallel_unordered_generator_returns_fastest_first_with_daskrƒ   n   s@   € ô 
×	Ñ	 a¸AÐ	Ò	>ÁÈÅÜ@ÀÀvÔN÷ AP×	>Ð	>ÇÅú×	>Õ	>úó   •	Až<«A¼
A
	ÁAÁ
AÚ	return_asÚ	generatorÚgenerator_unorderedc                 ó¼   • [         R                  SSS9   U " S5         [        S X5        S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       g = fr   )r   r   r   )r}   r…   r{   s      r1   Ú%test_deadlock_with_generator_and_daskr‰   u   s@   € ô
 
×	Ñ	 a¸AÐ	Ò	>ÁÈÅÜ% d¨IÔ>÷ AP×	>Ð	>ÇÅú×	>Õ	>úr„   c                 ó4  • [         R                  SSS9   [        R                  " [	        S5      [        R
                  S9n[        S5       HG  nU " S5         [        US9nS S S 5        [        W5      S:X  d   e[        S U 5       5      (       a  MG   e   U " S5         [        5       nS S S 5        [        W5      S:X  d   e[        S	 U 5       5      (       d   e S S S 5        g ! , (       d  f       N‹= f! , (       d  f       NS= f! , (       d  f       g = f)
Nr
   r€   g    ÐcA©Údtyper   ©Údataé   c              3   ó0   #   • U  H  u  pUS :H  v •  M     g7f©r   Nr5   ©rY   Únamerq   s      r1   r[   Ú4test_nested_parallelism_with_dask.<locals>.<genexpr>ˆ   s   é € ð Ú@X±W°T�Ð0Ö0Ò@Xùó   ‚c              3   ó0   #   • U  H  u  pUS :H  v •  M     g7fr‘   r5   r’   s      r1   r[   r”   �   s   é € ð 
Ú<T±°ˆDÐ,Ö,Ò<Tùr•   )
r   r   r   Úonesry   Úuint8rc   r   rF   Úall)r}   rŽ   rZ   Úbackend_types_and_levelss       r1   Ú!test_nested_parallelism_with_daskr›   ~   sü   € ô 
×	Ñ	 a¸AÐ	Ò	>ä�wŠw”s˜3“x¤r§x¡xÑ0ˆÜ�q–ˆAÙ˜•Ü+BÈÑ+MÐ(÷ !äÐ/Ó0°AÓ5Ð5Ð5Üñ Ù@Xó÷ ó ð ð ñ	 ñ �V�_Ü'>Ó'@Ð$÷ äÐ+Ó,°Ó1Ð1Ð1Üñ 
Ù<Tó
÷ 
ñ 
ð 	
ñ 
÷ 
?Ð	>÷ !•ú÷ �_ú÷ 
?Õ	>úsB   •AD	Á
C'Á".D	ÂD	Â C8Â+2D	Ã'
C5Ã1D	Ã8
D	ÄD	Ä	
Dc                  ó   • [        5       $ r4   r   r5   r9   r1   Úrandom2r�   •   s	   € Ü‹8€Or9   c           	      ó>  • [        5        u  nu  p#[        US   U S9 n[        SS9   [        5       " S [	        S5       5       5      u  pVXV:w  d   e S S S 5        S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       N(= f! , (       d  f       g = f)NrQ   rR   r   rT   c              3   óJ   #   • U  H  n[        [        5      " 5       v •  M     g 7fr4   )r   r�   rX   s     r1   r[   Ú3test_dont_assume_function_purity.<locals>.<genexpr>�   s   é € Ð!Gºh¸¤'¬'Ô"2×"4Ð"4ºhùó   ‚!#r
   ©r   r   r   r   rc   )rS   rf   rg   rh   rI   ÚxÚys          r1   Ú test_dont_assume_function_purityr¥   ™   sq   € Ü	Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0Ü”zÑ!G¼eÀA¼hÓ!GÓG‘�Ø“v�‘v÷ 1÷ -÷ 
ˆç0Õ0ú÷ -Õ,ú÷ 
�ús9   ‹Bž
A=¨*A,ÁA=ÁBÁ,
A:Á6A=Á=
B	ÂBÂ
BÚmixedFc                 óä  • SSK Jn  U(       d1  [        S5       Vs/ s H  n[        [        5      " U5      PM     nnSnON[        S5       Vs/ s H6  o3S-  (       a  [        [
        5      " U5      O[        [        5      " U5      PM8     nnSn[        U" U5      5      U:X  d   e[        5        u  nu  px[        US   U S9 n	[        S	S
9   [        SSS9" U5      n
S S S 5        S nUR                  SS5      nU	R                  U5      n[        S U 5       5      (       d   e S S S 5        S S S 5        g s  snf s  snf ! , (       d  f       Ni= f! , (       d  f       N2= f! , (       d  f       g = f)Nr   )ÚBatchr�   Úbatch_of_inc_4_callsr
   Úmixed_batch_of_inc_4_callsrQ   rR   r   rT   r™   )Ú
batch_sizeÚpre_dispatchc                 ó,   • [        U R                  5      $ r4   )rG   Útransition_log)Údask_schedulers    r1   ÚfÚtest_dask_funcname.<locals>.f³   s   € Ü˜N×9Ñ9Ó:Ð:r9   Ú4Ú2c              3   ó2   #   • U  H  nS US   ;   v •  M     g7f)Úbatch_of_incr   Nr5   )rY   Útups     r1   r[   Ú%test_dask_funcname.<locals>.<genexpr>¸   s   é € Ð?º3°C�~¨¨Q©Ö/º3ùs   ‚)Újoblib._daskr¨   rc   r   r    ÚabsÚreprr   r   r   r   ÚreplaceÚrun_on_schedulerr™   )rS   r¦   r¨   rZ   ÚtasksÚ
batch_reprrf   rg   rh   rI   rq   r°   rA   s                r1   Útest_dask_funcnamer¿   ¡   s&  € å"æÜ*/°¬(Ó3ª( Q”œ”˜a–©(ˆÐ3Ø+‰
äHMÈaÌÓQÊÀ1¨§E”œ”˜a”¬w´s¬|¸A«Ò>ÉˆÐQØ1ˆ
ä‘�e“Ó Ó+Ð+Ð+ä	Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0Ü¨¸Ò>¸uÓE�÷ 1ò;ð $×+Ñ+¨C°Ó5ˆJØ×)Ñ)¨!Ó,ˆCÜÑ?¹3Ó?×?Ñ?Ð?Ñ?÷ -÷ 
ˆùò 4ùò R÷ 1Õ0ú÷ -Õ,ú÷ 
�úsH   ›D5Á=D:Â.E!Ã
EÃD?ÃAEÄ$E!Ä?
EÅ	EÅ
E	ÅE!Å!
E/c                  ó4  ^^^	• [        S5       V s/ s H  n / PM     nn [        R                  " S5      m	T	R                  " [	        S5      5      mSUU	4S jjm[        SSS9n[        U5      n [        SS	9   [        5       " U4S
 jU 5       5      nS S S 5        U[        S5       V s/ s H  n / PM     sn :X  d   e[        SU5      n[        UR                  5       5      S:X  d   e[        W Vs/ s H  n[        U5      S:H  PM     sn5      (       d   e[        SS	9   [        5       " UU4S jU 5       5      nS S S 5        [        SU5      n[        UR                  5       5      S:”  d   e[        U Vs/ s H  n[        U5      S:H  PM     sn5      (       d   e UR                  SS9  UR                  " SS9  g s  sn f ! , (       d  f       GN8= fs  sn f s  snf ! , (       d  f       Nª= fs  snf ! UR                  SS9  UR                  " SS9  f = f)Néd   Únumpyg    €„.Ac                 óŒ   >• Ub  TR                   R                  UT5        U R                  [        5       R                  5        U $ r4   )ÚtestingÚassert_array_equalÚappendr	   Úhex)Úlist_rŽ   ÚXr   s     €€r1   Úisolated_operationÚCtest_no_undesired_distributed_cache_hit.<locals>.isolated_operationÊ   s4   ø€ ØÑØ�J‰J×)Ñ)¨$°Ô2Ø�‰”U“W—[‘[Ô!Øˆr9   r   r
   r€   r   rT   c              3   óF   >#   • U  H  n[        T5      " U5      v •  M     g 7fr4   ro   )rY   rÈ   rÊ   s     €r1   r[   Ú:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>Õ   s   øé € ÐSÊUÀEœWÐ%7Ô8¸×?Ð?ÊUùs   ƒ!úreceive-from-scatterr   c              3   óD   >#   • U  H  n[        T5      " UTS 9v •  M     g7f)r�   Nro   )rY   rÈ   rÉ   rÊ   s     €€r1   r[   rÍ   å   s!   øé € ð ÚHM¸u”Ð*Ô+¨E¸Ö:Êùó   ƒ é   ©Útimeoutr4   )rc   rd   ÚimportorskipÚarangery   r   r   r   r   rO   ÚsumÚvaluesr™   rF   Úclose)
rq   Úlistsr   rI   ÚresÚcountsÚrrÉ   rÊ   r   s
          @@@r1   Ú'test_no_undesired_distributed_cache_hitrÝ   »   sÈ  ú€ ô ˜sœÓ$š�A‹R™€EÐ$Ü	×	Ò	˜WÓ	%€BØ
�	Š	”#�c“(Ó€A÷ð ô  Q¸1Ñ=€GÜ�G‹_€Fð"Ü VÓ,ä”*ÔSÉUÓSÓSˆC÷ -ð ¤U¨3¤ZÓ0¢Z ›¡ZÑ0Ó0Ð0Ð0ô
 Ð4°fÓ=ˆÜ�6—=‘=“?Ó# qÓ(Ð(Ð(Ü©Ó-ª A”C˜“F˜a”K©Ñ-×.Ñ.Ð.Ð.ä VÓ,ô ”*õ ÙHMóó ˆC÷ -ô Ð4°fÓ=ˆÜ�6—=‘=“?Ó# aÓ'Ð'Ð'Ü©Ó-ª A”C˜“F˜a”K©Ñ-×.Ñ.Ð.Ñ.à�‰˜RˆÑ Ø�Š˜bÓ!ùòS %÷ -Ö,üò 1ùò .ç,Õ,üò .øà�‰˜RˆÑ Ø�Š˜bÓ!úse   ‘F?Á/	G6 Á8GÂG6 Â)GÂ5<G6 Ã1GÄ	G6 Ä G Ä<<G6 Å8G1ÆG6 Ç
GÇG6 Ç 
G.Ç*G6 Ç6!Hc                   ó*   • \ rS rSrS rS r\rS rSrg)ÚCountSerializedéò   c                 ó   • Xl         SU l        g )Nr   )r£   Úcount)Úselfr£   s     r1   Ú__init__ÚCountSerialized.__init__ó   s   € ØŒØˆ�
r9   c                 ó6   • U R                   [        USU5      -   $ )Nr£   )r£   Úgetattr)rã   Úothers     r1   Ú__add__ÚCountSerialized.__add__÷   s   € Ø�v‰vœ  s¨EÓ2Ñ2Ð2r9   c                 óR   • U =R                   S-  sl         [        U R                  44$ )Nr   )râ   rß   r£   )rã   s    r1   Ú
__reduce__ÚCountSerialized.__reduce__ü   s    € Ø�
Š
�a‰�
Ü $§&¡& Ð+Ð+r9   )râ   r£   N)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__rä   ré   Ú__radd__rì   Ú__static_attributes__r5   r9   r1   rß   rß   ò   s   † òò3ð €Hõ,r9   rß   c                 ó   • X-   U-   U-   U-   $ r4   r5   )rg   rh   ÚcÚdÚes        r1   Úadd5rø     s   € Ø‰5�1‰9�q‰=˜1ÑÐr9   c                 óÈ  ^• S [        S5       5       u  pp4[        [        5      n[        S5       Vs/ s H  oe" X#USSS9PM     nnUU" X$USSS9U" X2XBSS9U" XDX$US9/-  nU VV	V
s/ s H  u  p‰o¨" U	0 U
D6PM     nn	nn
[        5        u  pÆ[	        US   U S9 n[        SXU/S	9   [        S
S9" U5      nXë:X  d   e S S S 5        [        R                  " [        5         [        SU S
S9    S S S 5        S S S 5        S S S 5        S S S 5        UR                  nUR                  U:X  d   eUR                  U:X  d   eUR                  nXX44 H
  nSUl
        M     [        5        u  pÆ[	        US   U S9 n[        5       mXU4 H  nUR                  USS9T[        U5      '   M!     U VV	V
s/ s Hj  u  p‰n
UR                  " U/U4S jU	 5       Q70 [        U4S jU
R                  5        5       5      DS[!        [#        5       5      0D6R%                  5       PMl     nn	nn
UU:X  d   e S S S 5        S S S 5        UR                  nUR                  U:X  d   eUR                  U:X  d   eUU:X  d   e['        S [(        R*                  R-                  S5       5       5      nUS:  a  UR                  US
-   :X  d   eg UR                  U:X  d   eg s  snf s  sn
n	nf ! , (       d  f       GN'= f! , (       d  f       GN	= f! , (       d  f       GN= f! , (       d  f       GN= f! , (       d  f       GN'= fs  sn
n	nf ! , (       d  f       GN= f! , (       d  f       GN$= f)Nc              3   ó8   #   • U  H  n[        U5      v •  M     g 7fr4   )rß   rX   s     r1   r[   Ú&test_manual_scatter.<locals>.<genexpr>  s   é € Ð7ªh¨”/ !×$Ð$ªhùó   ‚r�   r_   é   )rö   r÷   rQ   rR   r   )rU   Úscatterr   )r«   )rU   rS   rþ   r   T)Ú	broadcastc              3   óZ   >#   • U  H   nTR                  [        U5      U5      v •  M"     g 7fr4   ©r*   Úid)rY   ÚargÚ	scattereds     €r1   r[   rû   :  s#   øé € ÐBºT°c�i—m‘m¤B s£G¨S×1Ð1ºTùs   ƒ(+c              3   ób   >#   • U  H$  u  pUTR                  [        U5      U5      4v •  M&     g 7fr4   r  )rY   ÚkeyÚvaluer  s      €r1   r[   rû   ;  s.   øé € ð â,:™L˜Sð ˜iŸm™m¬B¨u«I°uÓ=Õ>Ú,:ùs   ƒ,/r  c              3   ó8   #   • U  H  n[        U5      v •  M     g 7fr4   )ry   )rY   r0   s     r1   r[   rû   M  s   é € ÐSÒ0R¨1¤ A§ Ò0Rùrü   Ú.)iç  r�   )rc   r   rø   r   r   r   r   rd   re   Ú	TypeErrorrâ   Údictrþ   r  Úsubmitr+   Ústrr	   ÚresultÚtupler   Ú__version__Úsplit)rS   rL   r£   r¤   Úzr°   rq   r½   Úfuncr6   r7   Úexpectedrf   rI   Úresults_parallelÚ%n_serialization_scatter_with_parallelÚn_serialization_with_parallelÚvarÚobjÚresults_nativeÚn_serialization_scatter_nativeÚdistributed_versionr  s                         @r1   Útest_manual_scatterr    s=  ø€ ñ 8¬e°A¬hÓ7�J€Aˆ!ä”‹€AÜ+0°¬9Ó5ª9 aˆQˆq�Q˜!˜qÔ!©9€EÐ5Ø	Ù	ˆ!��Q˜!ÑÙ	ˆ!�˜!ÑÙ	ˆ!�˜!Ñðñ €Eñ
 AFÕFÂÑ*<¨$°f��dÐ%˜fÔ%Á€HÒFä	Œ‘f�qÜ�A�i‘L tÒ,°Ü ¨¸!À¸ÓCÜ#+°qÒ#9¸%Ó#@Ð Ø'Ó3Ð3Ñ3÷ Dô —’œyÕ)Ü$¨V¸$ÈÓJØ÷ K÷ *÷ -÷ 
ð -.¯G©GÐ)Ø�7‰7Ð;Ó;Ð;Ð;Ø�7‰7Ð;Ó;Ð;Ð;Ø$%§G¡GÐ!ð �a‹|ˆØˆŽ	ñ ô 
Œ‘f�qÜ�A�i‘L tÒ,°Ü›ˆIØ˜Q“w�Ø%+§^¡^°CÀ4 ^Ð%H�	œ"˜S›'Ó"ñ ñ -2õò -2Ñ(�T ð —’ØðäB¹TÓBòô ô à,2¯L©L¬Nóó ñô œE›G›ò÷ ‘&“(òñ -2ð ò ð " XÓ-Ð-Ñ-÷! -÷ 
ð* &'§W¡WÐ"Ø�7‰7Ð4Ó4Ð4Ð4Ø�7‰7Ð4Ó4Ð4Ð4à0Ð4RÓRÐRÐRäÑS´×0GÑ0G×0MÑ0MÈcÔ0RÓSÓSÐØ˜YÓ&ð
 �w‰wÐ7¸!Ñ;Ó;Ð;Ñ;à�w‰wÐ7Ó7Ð7Ñ7ùòG 6ùô G÷ DÖCú÷ KÖJú÷ *Ö)ú÷ -Ö,ú÷ 
Žüô:÷	 -Ö,ú÷ 
Žús®   ³KÁ(KÂ
L'ÂLÂ'KÂ?"LÃ!LÃ-K1	Ã/LÃ7LÃ?L'Å'MÅ78M Æ/A1L9È M È-MË
K.Ë)LË1
L Ë;LÌ
LÌLÌ
L$	ÌL'Ì'
L6Ì9M Í 
M	Í
MÍ
M!c           	      óÀ  ^	• [         R                  " S5      nUR                  " [        S5      UR                  S9m	UR                  " [        S5      UR                  S9nT	/S-  U/S-  -   n[        5        u  nu  pV[        US   U S9 n[        SS9   [        5       " S	 [        U5       5       5        S S S 5        [        S
U5      nX…S      X†S      -   S:X  d   e S S S 5        S S S 5        [        5        u  nu  pV[        US   U S9 n[        SS9   [        5       " U	4S j[        S5       5       5        S S S 5        [        S
U5      nX…S      S:X  d   eX†S      S:X  d   e S S S 5        S S S 5        g ! , (       d  f       NË= f! , (       d  f       N²= f! , (       d  f       N»= f! , (       d  f       Ny= f! , (       d  f       N[= f! , (       d  f       g = f)NrÂ   rs   r‹   ra   rQ   rR   r   rT   c              3   óN   #   • U  H  u  p[        [        5      " X"XS 9v •  M     g7f))ÚoptN©r   r8   )rY   rZ   rŽ   s      r1   r[   Ú$test_auto_scatter.<locals>.<genexpr>f  s$   é € ð â#=™˜ô œD”M $¨aÖ:Ú#=ùs   ‚#%rÎ   r
   c              3   óV   >#   • U  H  n[        [        5      " TS S U5      v •  M      g 7f)Nra   r!  )rY   rZ   Údata1s     €r1   r[   r"  s  s%   øé € ÐIÂ¸1œ7¤4œ=¨¨r°¨°A×6Ð6Âùs   ƒ&)rý   r   )rd   rÔ   r—   ry   r˜   r   r   r   r   Ú	enumeraterO   rc   )
Úloop_in_threadr   Údata2Údata_to_processrf   rg   rh   rI   rÛ   r$  s
            @r1   Útest_auto_scatterr)  [  s”  ø€ Ü	×	Ò	˜WÓ	%€BØ�GŠG”C˜“H B§H¡HÑ-€EØ�GŠG”C˜“H B§H¡HÑ-€EØ�w ‘{¨ w°¡{Ñ3€Oä	Œ‘k�q™&˜1Ü�A�i‘L ~Ò6¸&Ü ¨Ó0ô ”
ñ ä#,¨_Ô#=óô ÷ 1ô "Ð"8¸&ÓAˆFØ˜I™,Ñ'¨&°9±Ñ*>Ñ>À!ÓCÐCÑC÷ 7÷ 
ô 
Œ‘k�q™&˜1Ü�A�i‘L ~Ò6¸&Ü ¨Ó0Ü”
ÔIÄÀaÄÓIÔI÷ 1ô "Ð"8¸&ÓAˆFØ˜I™,Ñ'¨1Ó,Ð,Ð,Ø˜I™,Ñ'¨1Ó,Ð,Ñ,÷ 7÷ 
ˆ÷ 1Õ0ú÷ 7Õ6ú÷ 
�ú÷" 1Õ0ú÷ 7Õ6ú÷ 
�úsx   Á7FÂ

FÂ!E:Â5)FÃFÃ9GÄ
F>Ä$F-Ä:.F>Å)GÅ:
FÆFÆ
F	ÆFÆ
F*Æ-
F;Æ7F>Æ>
G	ÇGÇ
GÚretry_noc           	      ó®  ^^^	^
^• [         R                  " S5      m
SmSnU
4S jm	UU	4S jm[        5        u  nu  pE[        US   U S9 n[	        SS9   T
R
                  " S	5      m[        5       " UU4S
 j[        U5       5       5      nS S S 5        S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       N(= f! , (       d  f       g = f)NrÂ   r_   c                 ó(   >• TR                   " U 5      $ r4   )rÖ   )r£   rZ   Újr   s      €r1   Úmy_sumÚ#test_nested_scatter.<locals>.my_sum‚  s   ø€ Ø�vŠv�a‹yÐr9   c                 óÂ   >^ ^• [        5       n[        SS9   [        5       " U UU4S j[        T5       5       5      nS S S 5        [	        W5      $ ! , (       d  f       N= f)Nr   rT   c              3   óP   >#   • U  H  n[        T5      " TUS  TU5      v •  M     g 7fr4   ro   )rY   r-  ÚarrayrZ   r.  s     €€€r1   r[   ÚEtest_nested_scatter.<locals>.outer_function_joblib.<locals>.<genexpr>ˆ  s+   øé € ð !Ú:P°Q”˜”  a b 	¨1¨a×0Ð0Ò:Pùs   ƒ#&)r   r   r   rc   rÖ   )r2  rZ   rI   ÚresultsÚNUM_INNER_TASKSr.  s   ``  €€r1   Úouter_function_joblibÚ2test_nested_scatter.<locals>.outer_function_joblib…  sJ   ú€ Ü“ˆÜ VÓ,Ü”jö !Ü:?ÀÔ:Pó!ó ˆG÷ -ô �7‹|Ð÷	 -Õ,ús   —&AÁ
ArQ   rR   r   rT   i'  c              3   óN   >#   • U  H  n[        T5      " TUS  U5      v •  M     g 7fr4   ro   )rY   rZ   Úmy_arrayr6  s     €€r1   r[   Ú&test_nested_scatter.<locals>.<genexpr>‘  s.   øé € ð â3˜ô Ð1Ô2°8¸A¸B°<À×CÐCÚ3ùó   ƒ"%)rd   rÔ   r   r   r   r—   r   rc   )rS   r*  ÚNUM_OUTER_TASKSrf   rg   rh   rq   r5  r9  r.  r   r6  s          @@@@@r1   Útest_nested_scatterr=  {  s¢   ü€ ä	×	Ò	˜WÓ	%€Bà€OØ€Oõöô 
Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0ØŸ7š7 5›>�Ü”Jõ ä" ?Ô3óó �÷ 1÷ -÷ 
ˆç0Õ0ú÷ -Õ,ú÷ 
�ús;   ·CÁ

B5Á7B$ÂB5ÂCÂ$
B2Â.B5Â5
C	Â?CÃ
Cc           	      óš  ^• S m[        5        u  nu  p#[        US   U S9 n[        SS9   [        SS9" U4S j[	        S	5       5       5      nU H  n[        [        U5      5      S::  a  M   e   S S S 5        S S S 5        [        US   U S9 n[        SS9   [        SS9" U4S
 j[	        S	5       5       5      nU H  n[        [        U5      5      S::  a  M   e   S S S 5        S S S 5        S S S 5        g ! , (       d  f       NŒ= f! , (       d  f       N•= f! , (       d  f       NA= f! , (       d  f       NJ= f! , (       d  f       g = f)Nc            	      ó¬   • [        [        SS9" S [        S5       5       5      5      n U [        [        SS9" S [        S5       5       5      5      -  n U $ )Nr
   ©r{   c              3   ó^   #   • U  H#  n[        [        R                  5      " 5       v •  M%     g 7fr4   ©r   r(   Úgetpidrp   s     r1   r[   ÚOtest_nested_backend_context_manager.<locals>.get_nested_pids.<locals>.<genexpr>™  s   é € Ð%MÂH¸q¤g¬b¯i©iÔ&8×&:Ð&:ÂHùó   ‚+-c              3   ó^   #   • U  H#  n[        [        R                  5      " 5       v •  M%     g 7fr4   rB  rp   s     r1   r[   rD  š  s   é € Ð&NÂXÀ¤w¬r¯y©yÔ'9×';Ð';ÂXùrE  )Úsetr   rc   )Úpidss    r1   Úget_nested_pidsÚ<test_nested_backend_context_manager.<locals>.get_nested_pids˜  sH   € Ü”8 1Ò%Ñ%MÄEÈ!ÄHÓ%MÓMÓNˆØ””H AÒ&Ñ&NÄUÈ1ÄXÓ&NÓNÓOÑOˆØˆr9   rQ   rR   r   rT   r
   r@  c              3   óD   >#   • U  H  n[        T5      " 5       v •  M     g 7fr4   ro   ©rY   rq   rI  s     €r1   r[   Ú6test_nested_backend_context_manager.<locals>.<genexpr>   ó   øé € ð 0Ú8A°1”G˜OÔ,×.Ð.º	ùrÐ   r_   c              3   óD   >#   • U  H  n[        T5      " 5       v •  M     g 7fr4   ro   rL  s     €r1   r[   rM  ©  rN  rÐ   )r   r   r   r   rc   rF   rG  )r&  rf   rg   rh   rI   Ú
pid_groupsÚ	pid_grouprI  s          @r1   Ú#test_nested_backend_context_managerrR  —  s  ø€ òô
 
Œ‘k�q™&˜1Ü�A�i‘L ~Ò6¸&Ü ¨Ó0Ü%¨QÒ/ô 0Ü8=¸b¼	ó0ó �
ó ",�IÜœs 9›~Ó.°!Õ3Ð3Ð3ñ ",÷	 1÷ 7ô �A�i‘L ~Ò6¸&Ü ¨Ó0Ü%¨QÒ/ô 0Ü8=¸b¼	ó0ó �
ó ",�IÜœs 9›~Ó.°!Õ3Ð3Ð3ñ ",÷	 1÷ 7÷ 
ˆç0Õ0ú÷ 7Õ6ú÷ 1Õ0ú÷ 7Õ6ú÷ 
�úsu   �D<¢
D	¬>C8Á.C8Á2D	Á:D<Â
D+Â>DÃDÃD+Ã'D<Ã8
DÄD	Ä	
D	ÄD<Ä
D(Ä$D+Ä+
D9	Ä5D<Ä<
E
c           
      óô  ^	^
• S m	U	4S jm
[        5        u  nu  p#[        US   U S9 n[        SS9   [        5        nT	" U5      S:X  d   eUR                  S:X  d   eU" U
4S	 j[        S
5       5       5      nS S S 5        W H  u  pxUS:X  d   eUS:X  a  M   e   S S S 5        S S S 5        S S S 5        g ! , (       d  f       NB= f! , (       d  f       N0= f! , (       d  f       N9= f! , (       d  f       g = f)Nc                 óB   • U R                   R                  R                  $ r4   )ru   Ú	__class__rî   )Úps    r1   Ú_backend_typeÚJtest_nested_backend_context_manager_implicit_n_jobs.<locals>._backend_type´  s   € Ø�z‰z×#Ñ#×,Ñ,Ð,r9   c                  óv   >• [        5        n T" U 5      U R                  4sS S S 5        $ ! , (       d  f       g = fr4   )r   r{   )rV  rW  s    €r1   Úget_nested_implicit_n_jobsÚWtest_nested_backend_context_manager_implicit_n_jobs.<locals>.get_nested_implicit_n_jobs·  s%   ø€ ÜŒZ˜1Ù  Ó# Q§X¡XÐ-÷ �Z�Zús   Œ*ª
8rQ   rR   r   rT   r   r|   c              3   óD   >#   • U  H  n[        T5      " 5       v •  M     g 7fr4   ro   )rY   rq   rZ  s     €r1   r[   ÚFtest_nested_backend_context_manager_implicit_n_jobs.<locals>.<genexpr>Á  s    øé € ð *ÚGOÀ!œÐ :Ô;×=Ð=ÂxùrÐ   r
   )r   r   r   r   r{   rc   )rS   rf   rg   rh   rI   rV  Úall_nested_n_jobsÚbackend_typeÚnested_n_jobsrW  rZ  s            @@r1   Ú3test_nested_backend_context_manager_implicit_n_jobsra  °  sá   ù€ ò-õ.ô 
Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨Ó0Ü”Z 1Ù(¨Ó+Ð/GÓGÐGÐGØŸ8™8 r›>Ð)˜>Ù()ô *ÜGLÈQÄxó*ó )Ð%÷  ó 4EÑ/�LØ'Ð+CÓCÐCÐCØ(¨BÕ.Ð.Ð.ñ 4E÷ 1÷ -÷ 
ˆ÷  •Zú÷ 1Õ0ú÷ -Õ,ú÷ 
�úsV   –C)©
C³C¾<B6	Á:CÂCÂCÂ%C)Â6
CÃ CÃ
CÃCÃ
C&	Ã"C)Ã)
C7c                 ó  • [         R                  " [        5       n[        SS9    S S S 5        S S S 5        S[	        WR
                  5      R                  5       ;   d   eg ! , (       d  f       N@= f! , (       d  f       NI= f)Nr   rT   zcreate a dask client)rd   re   r;   r   r  r  Úlower)rS   Úinfos     r1   Útest_errorsre  É  sX   € Ü	�Š”zÔ	" dÜ VÓ,Ø÷ -÷ 
#ð "¤S¨¯©£_×%:Ñ%:Ó%<Ó<Ð<Ñ<÷ -Õ,ú÷ 
#Õ	"ús!   ›
A2¥A!§A2Á!
A/	Á+A2Á2
B c           	      ó0  • [        5        u  nu  p#[        US   U S9 n[        SS9   [        SS9" S [	        S5       5       5      n[        US	   S	   S	   [        5      (       d   e S S S 5        [        SS9   [        SS9" S
 [	        S5       5       5      n[        US	   S	   S	   [        5      (       d   e S S S 5        S S S 5        S S S 5        g ! , (       d  f       Nq= f! , (       d  f       N0= f! , (       d  f       N9= f! , (       d  f       g = f)NrQ   rR   r   rT   r
   r@  c              3   óH   #   • U  H  n[        [        5      " S S9v •  M     g 7f)N©Únested_require©r   Úouterrp   s     r1   r[   Ú.test_correct_nested_backend.<locals>.<genexpr>Ö  s   é € ð ,ÚAI¸A”GœE”N°$Ö7Âùó   ‚ "r   r   c              3   óH   #   • U  H  n[        [        5      " S S9v •  M     g7f)Ú	sharedmemrh  Nrj  rp   s     r1   r[   rl  Ý  s   é € ð ,ÚHPÀ1”GœE”N°+Ö>Êùrm  )r   r   r   r   rc   rv   r   r   )rS   rf   rg   rh   rI   r  s         r1   Útest_correct_nested_backendrp  Ñ  sî   € Ü	Œ‘k�q™&˜1Ü�A�i‘L tÒ,°ä ¨Ó0Ü!¨Ò+ñ ,ÜAFÀqÄó,ó �ô " &¨¡)¨A¡,¨q¡/Ô3I×JÑJÐJÑJ÷	 1ô !¨Ó0Ü!¨Ò+ñ ,ÜHMÈaÌó,ó �ô " &¨¡)¨A¡,¨q¡/Ô3C×DÑDÐDÑD÷	 1÷ -÷ 
ˆ÷ 1Õ0ú÷ 1Õ0ú÷ -Õ,ú÷ 
�úsS   ‹Dž
C6¨A CÁ)C6Á:A C%Â;C6ÃDÃ
C"ÃC6Ã%
C3Ã/C6Ã6
D	Ä DÄ
Dc                 óJ   ^ • [        SSS9" U 4S j[        S5       5       5      $ )Nr
   Úthreads)r{   Úpreferc              3   óN   >#   • U  H  n[        [        5      " T5      v •  M     g 7fr4   )r   Úmiddle)rY   rq   ri  s     €r1   r[   Úouter.<locals>.<genexpr>ä  s    øé € ð 0Ú19¨AŒ”Œ˜×'Ð'²ùr;  r   ©r   rc   rh  s   `r1   rk  rk  ã  s(   ø€ Ü˜1 YÒ/ô 0Ü16°q´ó0ó ð r9   c                 óB   • [        SU S9" S [        S5       5       5      $ )Nr
   )r{   Úrequirec              3   óJ   #   • U  H  n[        [        5      " 5       v •  M     g 7fr4   )r   Úinnerrp   s     r1   r[   Úmiddle.<locals>.<genexpr>ê  s   é € Ð.RÊÀA¬w´u¬~×/?Ð/?Êùr¡   r   rw  )ry  s    r1   ru  ru  é  s   € Ü˜1 gÒ.Ñ.RÌÈqÌÓ.RÓRÐRr9   c                  ó*   • [        5       R                  $ r4   )r   ru   r5   r9   r1   r{  r{  í  s   € Ü‹:×ÑÐr9   c                 óÒ   • [        U SSS9   [        SS9   [        SS9" S [        S	5       5       5        S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       g = f)
NFT)rS   Ú	processesÚset_as_defaultr   rT   r�   r@  c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   )r   r  rX   s     r1   r[   Ú0test_secede_with_no_processes.<locals>.<genexpr>õ  s   é € Ð@²x°!œw¤rœ{¨1Ÿ~˜~²xùr^   r
   )r   r   r   rc   rR   s    r1   Útest_secede_with_no_processesrƒ  ñ  sL   € ä	�T U¸4Ó	@Ü VÓ,Ü˜AÒÑ@´u¸Q´xÓ@Ô@÷ -÷ 
AÐ	@ß,Õ,ú÷ 
AÕ	@ús!   Œ
A– A¶AÁ
A	ÁAÁ
A&c                 ó0   • SSK Jn  U" 5       R                  $ )Nr   )Ú
get_worker)r   r…  rQ   )rq   r…  s     r1   Ú_worker_addressr†  ø  s   € Ý&á‹<×ÑÐr9   c           	      óü  • [        5        u  nu  p#[        US   U S9 n[        SUS   S9   [        5       " S [	        S5       5       5      nXRS   /S-  :X  d   e S S S 5        [        SUS   S9   [        5       " S [	        S5       5       5      nXSS   /S-  :X  d   e S S S 5        S S S 5        S S S 5        g ! , (       d  f       Nd= f! , (       d  f       N0= f! , (       d  f       N9= f! , (       d  f       g = f)NrQ   rR   r   )rU   Úworkersc              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   ©r   r†  rX   s     r1   r[   Ú-test_dask_backend_keywords.<locals>.<genexpr>  ó   é € Ð PÂiÀ¤¬Ô!9¸!×!<Ð!<Âiùr^   r_   c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rŠ  rX   s     r1   r[   r‹    rŒ  r^   r¢   )rS   rf   rg   rh   rI   ri   s         r1   Útest_dask_backend_keywordsrŽ  þ  sÑ   € Ü	Œ‘k�q™&˜1Ü�A�i‘L tÒ,°Ü ¨¸¸9¹ÓFÜ”jÑ PÄeÈBÄiÓ PÓP�Ø ™|˜n¨rÑ1Ó1Ð1Ñ1÷ Gô !¨¸¸9¹ÓFÜ”jÑ PÄeÈBÄiÓ PÓP�Ø ™|˜n¨rÑ1Ó1Ð1Ñ1÷ G÷ -÷ 
ˆçFÕFú÷ GÕFú÷ -Õ,ú÷ 
�úsQ   ‹C-žC¬/B:ÁCÁ1/CÂ!CÂ)C-Â:
CÃCÃ
CÃCÃ
C*	Ã&C-Ã-
C;c                 óâ  • [        SU S9 n[        SS9   [        5       " S [        S5       5       5        S S S 5        [	        5       nUR
                  R                  R                  (       aE  [        S5        [	        5       US-   :  d   eUR
                  R                  R                  (       a  ME  UR                  (       a   e S S S 5        g ! , (       d  f       NŸ= f! , (       d  f       g = f)	NF)r  rS   r   rT   c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   Ú/test_scheduler_tasks_cleanup.<locals>.<genexpr>  ó   é € Ð:²	¨1”wœs”| A—�²	ùr^   r_   g{®Gáz„?rý   )
r   r   r   rc   r   r   Ú	schedulerr½   r   Úfutures)rS   rI   Ústarts      r1   Útest_scheduler_tasks_cleanupr–  
  s§   € Ü	˜% dÒ	+¨vÜ VÓ,ÜŒJÑ:´°b´	Ó:Ô:÷ -ô “ˆØ�n‰n×&Ñ&×,×,Ü�$ŒKÜ“6˜E A™IÓ%Ð%Ð%ð �n‰n×&Ñ&×,×,Ñ,ð —>—>Ð!Ð!�>÷ 
,Ð	+ß,Õ,ú÷ 
,Õ	+ús(   ‹
C •!C¶A:C Â2C Ã
C	ÃC Ã 
C.Úcluster_strategyÚadaptiveÚlate_scalingz2.1.1z1.28.0z?distributed bug - https://github.com/dask/distributed/pull/2841)Úreasonc                 ó¦  • [        SSSS9n[        U5      nU S:X  a  UR                  " SSS9  OU S:X  a  UR                  " S5         [	        SS	9   [        5       " S
 [        S5       5       5        S S S 5        UR                  5         UR                  " 5         g ! , (       d  f       N0= f! UR                  5         UR                  " 5         f = f)Nr   Fr
   ©r�   r  r‚   r˜  )ÚminimumÚmaximumr™  r   rT   c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   Ú(test_wait_for_workers.<locals>.<genexpr>+  r’  r^   r_   )r   r   ÚadaptÚscaler   r   rc   rØ   )r—  r   rI   s      r1   Útest_wait_for_workersr£    s¡   € ô  Q°%ÈAÑN€GÜ�G‹_€FØ˜:Ó%Ø�Š˜a¨Ó+Ø	˜^Ó	+ð
 	�Š�aÔðÜ VÓ,ô ŒJÑ:´°b´	Ó:Ô:÷ -ð
 	�‰ŒØ�Š�÷ -Õ,ûð
 	�‰ŒØ�Š�ús$   Á	B- Á!BÁ2B- Â
B*Â&B- Â-#Cc                  ó¤  • [        SSSS9n [        U 5      n [        SSS9   Sn[        R                  " [
        US	9   [        5       " S
 [        S5       5       5        S S S 5        S S S 5        [        SSS9   Sn[        R                  " [        US	9   [        5       " S [        S5       5       5        S S S 5        S S S 5        UR                  5         U R                  " 5         g ! , (       d  f       N�= f! , (       d  f       N˜= f! , (       d  f       NZ= f! , (       d  f       Nc= f! UR                  5         U R                  " 5         f = f)Nr   Fr
   rœ  r   gš™™™™™¹?)rU   Úwait_for_workers_timeoutz7DaskDistributedBackend has no worker after 0.1 seconds.)Úmatchc              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   Ú0test_wait_for_workers_timeout.<locals>.<genexpr>:  ó   é € Ð>²I¨qœ7¤3œ<¨Ÿ?˜?²Iùr^   r_   z+DaskDistributedBackend has no active workerc              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   r¨  @  r©  r^   )
r   r   r   rd   re   ÚTimeoutErrorr   rc   ÚRuntimeErrorrØ   )r   rI   Úmsgs      r1   Útest_wait_for_workers_timeoutr®  1  sç   € ä Q°%ÈAÑN€GÜ�G‹_€FðÜ VÀcÓJàKˆCÜ—’œ|°3Ó7Ü”
Ñ>´E¸"´IÓ>Ô>÷ 8÷ Kô  VÀaÓHà?ˆCÜ—’œ|°3Ó7Ü”
Ñ>´E¸"´IÓ>Ô>÷ 8÷ Ið 	�‰ŒØ�Š�÷ 8Õ7ú÷ KÕJú÷ 8Õ7ú÷ IÕHûð 	�‰ŒØ�Š�úsi   ˜
D, ¢C9¾!C(ÁC9Á'D, Á9DÂ!D
Â6DÂ>D, Ã(
C6	Ã2C9Ã9
DÄD, Ä

D	ÄDÄ
D)Ä%D, Ä,#ErU   ÚlokyÚmultiprocessingc                 ó–  ^ • [        SS9n[        U5      n U 4S jnUR                  U5      nUR                  5       n[	        U5      S:X  d   eUS   R
                  n[        U[        5      (       d   eS[        U5      ;   d   e UR                  SS9  UR                  " SS9  g ! UR                  SS9  UR                  " SS9  f = f)	Nr
   )r�   c                  ó¦   >• [         R                  " SS9 n [        STS9" S [        S5       5       5        S S S 5        U $ ! , (       d  f       W $ = f)NT)Úrecordr
   )r{   rU   c              3   óL   #   • U  H  n[        [        5      " U5      v •  M     g 7fr4   rW   rX   s     r1   r[   Úftest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallel.<locals>.<genexpr>R  s   é € Ð3WÊYÈ´G¼C´LÀ·O°OÊYùr^   r_   )ÚwarningsÚcatch_warningsr   rc   )r³  rU   s    €r1   Úfunc_using_joblib_parallelÚStest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallelL  sK   ø€ ô
 ×(Ò(°Ò5¸Ü ¨7Ò3Ñ3WÌUÐSUÌYÓ3WÔW÷ 6ð ˆM÷ 6Ô5ð ˆMús   –!AÁ
Ar   r   zdistributed.worker.daemonrÑ   rÒ   )
r   r   r  r  rF   Úmessagerv   ÚUserWarningr  rØ   )rU   r   rI   r¸  Úfutr³  Úwarnings   `      r1   Ú/test_joblib_warning_inside_dask_daemonic_workerr¾  F  sº   ø€ ä QÑ'€GÜ�G‹_€Fð"õ	ð �m‰mÐ6Ó7ˆØ—‘“ˆä�6‹{˜aÓÐÐØ˜‘)×#Ñ#ˆÜ˜'¤;×/Ñ/Ð/Ð/Ø*¬c°'«lÓ:Ð:Ñ:à�‰˜RˆÑ Ø�Š˜bÓ!øð 	�‰˜RˆÑ Ø�Š˜bÓ!ús   —A/B' Â'!C)gš™™™™™©?)r   r   )PÚ
__future__r   r   r   r(   r¶  r   r   r   Úuuidr	   rd   Ú r   r   r   r   Ú_daskr   rw   r   r   Úcommonr   r   Útest_parallelr   r   r   rÔ   r   r   r   r   r   Údistributed.metricsÚdistributed.utils_testr   r   r    Úfixturer2   r8   r>   rO   rj   rz   ÚmarkÚparametrizerƒ   r‰   r›   r�   r¥   r¿   rÝ   Úobjectrß   rø   r  r)  rG   rc   r=  rR  ra  re  rp  rk  ru  r{  rƒ  r†  rŽ  r–  Úskipifr  r£  r®  r¾  r5   r9   r1   Ú<module>rÌ     sí  ðß @Ñ @ã 	Û Ý Ý Ý ã ç CÓ CÝ *ß :ß "÷ñ ð ×!Ò! -Ó0€Ø×Ò˜6Ó"€÷ 9Ñ 8Ý $÷ 9Ñ 8ð ‡‚�j¨$Ñ/ñó 0ðò"	ô8òò:ò >ð. ‡�×Ñ˜ A r 7Ó+Ø‡�×Ñ˜ _Ð6FÐ$GÓHñOó Ió ,ðOð
 Ø‡�×Ñ˜ A r 7Ó+Ø‡�×Ñ˜ {Ð4IÐ&JÓKØ‡�×Ñ˜ _Ð6FÐ$GÓHñ?ó Ió Ló ,ó ð?ð
 Ø‡�×Ñ˜ _Ð6FÐ$GÓHñ
ó Ió ð
ò*òð ‡�×Ñ˜ 4¨ -Ó0ñ@ó 1ð@ò24"ôn,�fô ,ôòP8òl-ð@ ‡�×Ñ˜¡T©%°«(£^Ó4ñó 5ðò64ò2/ò2=òEò$òSòòAò ò	2ò
"ð ‡�×ÑÐ+¨j¸.Ð-IÓJØ‡�×ÑØ×Ñ˜wÑ&×N¨;×+BÑ+BÀhÑ+NØLð ð ñó	ó Kð
ò*ð* ‡�×Ñ˜ VÐ->Ð$?Ó@ñ"ó Añ"r9   