+
    €",i”Y  ã                   ót  € ^ RI HtHtHt ^ RIt^ RIt^ RIHt ^ RIHt ^ RI	H
t
 ^ RIt^RIHtHtHtHt ^RIHt ^RIHtHt ^R	IHtHt ^R
IHtHtHt ]P:                  ! R4      t]P:                  ! R4      t^ RIH t H!t!H"t" ^ RI#Ht ^ RI$H%t%H&t&H't' ]PP                  ! RRR7      R 4       t)R t*RFR lt+R t,R t-R t.]P^                  Pa                  R^RG.4      ]P^                  Pa                  R]].4      R 4       4       t1]]P^                  Pa                  R^RG.4      ]P^                  Pa                  RRR.4      ]P^                  Pa                  R]].4      R 4       4       4       4       t2]]P^                  Pa                  R]].4      R  4       4       t3R! t4R" t5]P^                  Pa                  R#RR$.4      R% 4       t6R& t7 ! R' R(]84      t9RHR) lt:R* t;R+ t<]P^                  Pa                  R,]=! ]>! ^4      4      4      R- 4       t?R. t@R/ tAR0 tBR1 tCR2 tDR3 tER4 tFR5 tGR6 tHR7 tIR8 tJ]P^                  Pa                  R9R:R;.4      ]P^                  P—                  ]P˜                  R<8*  ;'       d    ]P˜                  R=8¬  R>R?7      R@ 4       4       tMRA tN]P^                  Pa                  RBRCRD.4      RE 4       tOR# )Ié    )Ú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              #   ó@  "  € ^ RI Hp VP                   Uu/ uF"  q"\        P                  P                  V4      bK$  	  ppRx € VP                  4        F>  w  r$Vf#   \        P                  P                  VR4       K+  V\        P                  V&   K@  	  R# u upi 5i)r   )ÚParallelBackendBaseN)Újoblib._parallel_backendsr#   ÚMAX_NUM_THREADS_VARSÚosÚenvironÚgetÚitemsÚpop)Útmp_pathr#   ÚkÚ	old_valueÚvs   &    Ú7/usr/lib/python3/dist-packages/joblib/test/test_dask.pyÚavoid_dask_env_leaksr0   !   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                  ó   € R # ©N© )ÚargsÚkwargss   *,r/   Únoopr6   3   s   € Ùó    c                 óB   € \        V4       V '       d   \        R 4      hR# )zcondition evaluated to TrueN)r   Ú
ValueError)Ú	conditionÚdurations   &&r/   Úslow_raise_value_errorr<   7   s   € Ü	ˆ(„OßÜÐ6Ó7Ð7ñ r7   c                 óÔ   € VP                  R  4      p/ pVP                  4        F:  w  rE\        \        V4       Uu. uF  qf^,          V 8X  g   K  VNK  	  up4      W4&   K<  	  V# u upi )c                 ó   € V P                   # r2   )Úlog)Údask_workers   &r/   Ú<lambda>Úcount_events.<locals>.<lambda>>   s   € °;·?²?r7   )Úrunr)   ÚlenÚlist)Ú
event_nameÚclientÚworker_eventsÚevent_countsÚwÚeventsÚevents   &&     r/   Úcount_eventsrM   =   sf   € Ø—J‘JÑBÓC€MØ€LØ"×(Ñ(Ö*‰	ˆÜÜ $ V¤ÓG¡�u°aµ¸JÑ0F�UˆU¡ÑGó
ˆ‹ñ +ð Ðùò Hs   ¼A%
ÁA%
c                 ó<  € \        4       ;_uu_ 4       w  pw  r#\        VR ,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ! R \	        ^
4       4       4      pT\	        ^
4       Uu. uF  p\        V4      NK  	  up8X  g   Q h\        P                  ! \        4      ;_uu_ 4        \        4       ! R \	        ^
4       4       4       RRR4       \        4       ! R \	        ^
4       4       4      pT\	        ^
4       Uu. uF  p\        V4      NK  	  up8X  g   Q h RRR4       RRR4       RRR4       R# u upi   + '       g   i     L{; iu upi   + '       g   i     L?; i  + '       g   i     LJ; i  + '       g   i     R# ; i)Úaddress©Úloopr   ©Úbackendc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   ©r   r   ©Ú.0Úis   & r/   Ú	<genexpr>Útest_simple.<locals>.<genexpr>K   ó   é € Ð D¹)°Q¤¬¤¨a§ »)ùó   ‚"$c              3   óR   "  € T F  p\        \        4      ! V^8H  4      x € K  	  R# 5i)é   N)r   r<   rV   s   & r/   rY   rZ   O   s%   é € ð ÙIRÀAœÔ 6Ô7¸¸Q¹×?Ð?Ëùs   ‚%'Nc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   rZ   S   r[   r\   )	r   r   r   r
   Úranger   ÚpytestÚraisesr9   )rQ   ÚsÚaÚbrG   ÚseqrX   s   &      r/   Útest_simplerg   G   s  € Ü	�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö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ú÷ -×,ú÷ 
�ˆúsp   “"F
µE7	Á
/E$Á9EÂ+E$Â8!EÃ6E$ÄEÄ#	E$Ä-E7	Ä5F
ÅE$ÅEÅE$Å$E4Å/E7	Å7FÆF
Æ
F	c                 óÞ  € \         P                  \        P                  J g   Q h\        4       ;_uu_ 4       w  pw  r#\	        VR ,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ;_uu_ 4       pVP                  p\        V\         4      '       g   Q hVP                  VJ g   Q hVP                  ^8X  g   Q hV! R \        \        R4      4       4       4       VP                  ^
8”  g   Q h RRR4       RRR4       RRR4       RRR4       R#   + '       g   i     L*; i  + '       g   i     L5; i  + '       g   i     L@; i  + '       g   i     R# ; i)rO   rP   r   rR   c              3   óD   "  € T F  p\        R  4      ! 4       x € K  	  R# 5i)c                  ó   € R # r2   r3   r3   r7   r/   rA   Ú?test_dask_backend_uses_autobatching.<locals>.<genexpr>.<lambda>j   s   € ©Tr7   N©r   ©rW   Ú_s   & r/   rY   Ú6test_dask_backend_uses_autobatching.<locals>.<genexpr>j   s   é € ÐN¹o¸œW¡\Ô2×4Ð4»oùs   ‚ ç     ˆÃ@N)r   Úcompute_batch_sizer   r   r   r   r
   Ú_backendÚ
isinstanceÚparallelÚ_effective_batch_sizer`   Úint)rQ   rc   rd   re   rG   rt   rS   s   &      r/   Ú#test_dask_backend_uses_autobatchingrw   W   s
  € ä×1Ñ1Ü×/Ñ/ó	0ðð	0ô 
�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö0Ü—Z”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   ·"EÁE	Á.D5ÂA>D"Ä D5ÄE	ÄEÄ"D2Ä-D5Ä5EÅ E	ÅEÅEÅE,	Ún_jobsÚcontextc           	      óî   € \         P                  ^^R7      ;_uu_ 4        V! R4      ;_uu_ 4        \        RV 4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i©é   ©Ú	n_workersÚthreads_per_workerr   N)r   r   r   )rx   ry   s   &&r/   ÚAtest_parallel_unordered_generator_returns_fastest_first_with_daskr€   n   sH   € ô 
×	Ñ	 a¸AÐ	×	>Õ	>ÁÈÇÅÜ@ÀÀvÔN÷ AP×	>Ñ	>ÇÇú×	>×	>Ð	>úó!    A#±A	¾A#ÁA ÁA#Á#A4	Ú	return_asÚ	generatorÚgenerator_unorderedc           	      óî   € \         P                  ^^R7      ;_uu_ 4        V ! R4      ;_uu_ 4        \        RW4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; ir{   )r   r   r   )ry   r‚   rx   s   &&&r/   Ú%test_deadlock_with_generator_and_daskr†   u   sH   € ô
 
×	Ñ	 a¸AÐ	×	>Õ	>ÁÈÇÅÜ% d¨IÔ>÷ AP×	>Ñ	>ÇÇú×	>×	>Ð	>úr�   c           
      ó  € \         P                  ^^R7      ;_uu_ 4        \        P                  ! \	        R4      \        P
                  R7      p\        ^4       Fv  pV ! R4      ;_uu_ 4        \        VR7      pRRR4       \        X4      ^8X  g   Q h\        ;QJ d    R V 4       F  '       d   K   RM	  R	M! R V 4       4      '       d   Kv  Q h	  V ! R4      ;_uu_ 4        \        4       pRRR4       \        X4      ^8X  g   Q h\        ;QJ d    R
 V 4       F  '       d   K   RM	  R	M! R
 V 4       4      '       g   Q h RRR4       R#   + '       g   i     LÞ; i  + '       g   i     L|; i  + '       g   i     R# ; i)r|   r}   g    ÐcA©Údtyper   ©ÚdataNc              3   ó0   "  € T F  w  rVR 8H  x € K  	  R# 5i©r   Nr3   ©rW   Únamern   s   &  r/   rY   Ú4test_nested_parallelism_with_dask.<locals>.<genexpr>ˆ   s   é € ð Ù@X±W°T�Ð0Ö0Ó@Xùó   ‚FTc              3   ó0   "  € T F  w  rVR 8H  x € K  	  R# 5ir�   r3   rŽ   s   &  r/   rY   r�   �   s   é € ð 
Ù<T±°ˆDÐ,Ö,Ó<Tùr‘   )
r   r   r   Úonesrv   Úuint8r`   r   rD   Úall)ry   r‹   rX   Úbackend_types_and_levelss   &   r/   Ú!test_nested_parallelism_with_daskr—   ~   s0  € ô 
×	Ñ	 a¸AÐ	×	>Õ	>ä�wŠw”s˜3“x¤r§x¡xÔ0ˆÜ�q–ˆAÙ˜—•Ü+BÈÔ+MÐ(÷ !äÐ/Ó0°AÔ5Ð5Ð5ß“3ñ Ù@Xó—3—3’3ñ Ù@Xó÷ ô ð ð ñ	 ñ �V�_�_Ü'>Ó'@Ð$÷ äÐ+Ó,°Ô1Ð1Ð1ß‹sñ 
Ù<Tó
�s�sŠsñ 
Ù<Tó
÷ 
ò 
ð 	
ñ 
÷ 
?Ñ	>÷ !—ú÷ �_ú÷ 
?×	>Ð	>ús`    AE7Á.EÁ;$E7Â E7Â4E7ÃE7Ã%E$	Ã0$E7ÄE7Ä)E7ÅE7ÅE!ÅE7Å$E4Å/E7Å7F	c                  ó   € \        4       # r2   r   r3   r7   r/   Úrandom2r™   •   s	   € Ü‹8€Or7   c                 ó”  € \        4       ;_uu_ 4       w  pw  r#\        VR ,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ! R \	        ^4       4       4      w  rVWV8w  g   Q h RRR4       RRR4       RRR4       R#   + '       g   i     L"; i  + '       g   i     L-; i  + '       g   i     R# ; i)rO   rP   r   rR   c              3   óJ   "  € T F  p\        \        4      ! 4       x € K  	  R # 5ir2   )r   r™   rV   s   & r/   rY   Ú3test_dont_assume_function_purity.<locals>.<genexpr>�   s   é € Ð!G¹h¸¤'¬'Ô"2×"4Ð"4»hùó   ‚!#N©r   r   r   r
   r`   )rQ   rc   rd   re   rG   ÚxÚys   &      r/   Ú test_dont_assume_function_purityr¡   ™   s{   € Ü	�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö0Ü”zÑ!G¼eÀA¼hÓ!GÓG‘�Ø”v�‘v÷ 1÷ -÷ 
‰ç0×0ú÷ -×,ú÷ 
�ˆús:   “"B6µB#	Á
+BÁ6B#	Á>B6ÂB ÂB#	Â#B3Â.B6Â6C	ÚmixedFc                 óŽ  € ^ RI Hp V'       g1   \        ^4       Uu. uF  p\        \        4      ! V4      NK  	  ppRpMR\        ^4       Uu. uF;  q3^,          '       d   \        \
        4      ! V4      M\        \        4      ! V4      NK=  	  ppRp\        V! V4      4      V8X  g   Q h\        4       ;_uu_ 4       w  pw  rx\        VR,          V R7      ;_uu_ 4       p	\        RR7      ;_uu_ 4        \        ^RR	7      ! V4      p
R
R
R
4       R pVP                  RR4      pV	P                  V4      p\        ;QJ d    R V 4       F  '       d   K   RM	  RM! R V 4       4      '       g   Q h R
R
R
4       R
R
R
4       R
# u upi u upi   + '       g   i     L�; i  + '       g   i     L7; i  + '       g   i     R
# ; i)r   )ÚBatchÚbatch_of_inc_4_callsÚmixed_batch_of_inc_4_callsrO   rP   r   rR   r•   )Ú
batch_sizeÚpre_dispatchNc                 ó,   € \        V P                  4      # r2   )rE   Útransition_log)Údask_schedulers   &r/   ÚfÚtest_dask_funcname.<locals>.f³   s   € Ü˜N×9Ñ9Ó:Ð:r7   Ú4Ú2c              3   ó:   "  € T F  pR V^ ,          9   x € K  	  R# 5i)Úbatch_of_incNr3   )rW   Útups   & r/   rY   Ú%test_dask_funcname.<locals>.<genexpr>¸   s   é € Ð?¹3°C�~¨¨Q­Ö/»3ùs   ‚FT)Újoblib._daskr¤   r`   r   r   ÚabsÚreprr   r   r   r
   ÚreplaceÚrun_on_schedulerr•   )rQ   r¢   r¤   rX   ÚtasksÚ
batch_reprrc   rd   re   rG   rn   r¬   r?   s   &&           r/   Útest_dask_funcnamer»   ¡   sB  € å"çÜ*/°¬(Ó3©( Q”œ”˜a–©(ˆÐ3Ø+‰
äHMÈaÌÓQÉÀ1¨§E¤E”œ”˜a”¬w´s¬|¸A«Ò>ÉˆÐQØ1ˆ
ä‘�e“Ó Ô+Ð+Ð+ä	�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö0Ü¨¸Õ>¸uÓE�÷ 1ò;ð $×+Ñ+¨C°Ó5ˆJØ×)Ñ)¨!Ó,ˆCß“3Ñ?¹3Ó?—3—3’3Ñ?¹3Ó?×?Ò?Ð?Ñ?÷ -÷ 
‰ùò 4ùò R÷ 1×0ú÷ -×,ú÷ 
�ˆúsZ   œFÁAFÂ;"F3ÃF 	Ã2FÄ8F 	Ä?F 	ÅF 	Å.F 	Å1F3ÆFÆF 	Æ F0Æ+F3Æ3G	c                  óŠ  aaa	€ \        ^d4       U u. uF  p . NK  	  pp \        P                  ! R4      o	S	P                  ! \	        R4      4      oRVV	3R llo\        ^^R7      p\        V4      p \        RR7      ;_uu_ 4        \        4       ! V3R lV 4       4      pRRR4       T\        ^d4       U u. uF  p . NK  	  up 8X  g   Q h\        R	V4      p\        VP                  4       4      ^ 8X  g   Q h\        X Uu. uF  p\        V4      ^8H  NK  	  up4      '       g   Q h\        RR7      ;_uu_ 4        \        4       ! VV3R
 lV 4       4      pRRR4       \        R	V4      p\        VP                  4       4      ^ 8”  g   Q h\        V Uu. uF  p\        V4      ^8H  NK  	  up4      '       g   Q h VP                  ^R7       VP                  ! ^R7       R# u up i   + '       g   i     ELN; iu up i u upi   + '       g   i     L¶; iu upi   TP                  ^R7       TP                  ! ^R7       i ; i)éd   Únumpyg    €„.ANc                 óŽ   <€ Ve   SP                   P                  VS4       V P                  \        4       P                  4       V # r2   )ÚtestingÚassert_array_equalÚappendr	   Úhex)Úlist_r‹   ÚXr   s   &&€€r/   Úisolated_operationÚCtest_no_undesired_distributed_cache_hit.<locals>.isolated_operationÊ   s4   ø€ ØÒØ�J‰J×)Ñ)¨$°Ô2Ø�‰”U“W—[‘[Ô!Øˆr7   r}   r   rR   c              3   óF   <"  € T F  p\        S4      ! V4      x € K  	  R # 5ir2   rl   )rW   rÄ   rÆ   s   & €r/   rY   Ú:test_no_undesired_distributed_cache_hit.<locals>.<genexpr>Õ   s   øé € ÐSÉUÀEœWÐ%7Ô8¸×?Ð?ËUùs   ƒ!úreceive-from-scatterc              3   óJ   <"  € T F  p\        S4      ! VSR 7      x € K  	  R# 5i)rŠ   Nrl   )rW   rÄ   rÅ   rÆ   s   & €€r/   rY   rÉ   å   s$   øé € ð ÙHM¸u”Ð*Ô+¨E¸×:Ñ:Ëùs   ƒ #©Útimeoutr2   )r`   ra   ÚimportorskipÚarangerv   r   r   r   r
   rM   ÚsumÚvaluesr•   rD   Úclose)
rn   Úlistsr   rG   ÚresÚcountsÚrrÅ   rÆ   r   s
          @@@r/   Ú'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Ö!úsq   ‘G Á1H ÂG%Â H Â6G9Ã>H Ã?G>ÄH Ä#H Ä9HÅ=H ÆHÆ)H Æ6H Ç%G6	Ç0H ÈH	ÈH È'Ic                   ó6   a € ] tR t^òt o R tR t]tR tRtV t	R# )ÚCountSerializedc                ó    € Wn         ^ V n        R# )r   N)rŸ   Úcount)ÚselfrŸ   s   &&r/   Ú__init__ÚCountSerialized.__init__ó   s   € ØŒØˆŽ
r7   c                ó>   € V P                   \        VR V4      ,           # )rŸ   )rŸ   Úgetattr)rÜ   Úothers   &&r/   Ú__add__ÚCountSerialized.__add__÷   s   € Ø�v‰vœ  s¨EÓ2Õ2Ð2r7   c                óZ   € V ;P                   ^,          un         \        V P                  33# )é   )rÛ   rÙ   rŸ   )rÜ   s   &r/   Ú
__reduce__ÚCountSerialized.__reduce__ü   s    € Ø�
Š
�a��
Ü $§&¡& Ð+Ð+r7   )rÛ   rŸ   N)
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__rÝ   râ   Ú__radd__ræ   Ú__static_attributes__Ú__classdictcell__)Ú__classdict__s   @r/   rÙ   rÙ   ò   s    ø‡ € òò3ð €H÷,ð ,r7   rÙ   c                 ó<   € W,           V,           V,           V,           # r2   r3   )rd   re   ÚcÚdÚes   &&&&&r/   Úadd5rô     s   € Ø�5�1�9�q�=˜1ÕÐr7   c                 ó0  a€ R  \        ^4       4       w  rr4\        \        4      p\        ^
4       Uu. uF  qe! W#V^^R7      NK  	  ppVV! W$V^^R7      V! W2WB^R7      V! WDW$VR7      .,          pV UU	U
u. uF  w  r‰q¨! V	/ V
B NK  	  pp	pp
\        4       ;_uu_ 4       w  rÆ\	        VR,          V R7      ;_uu_ 4       p\        RWV.R7      ;_uu_ 4        \        ^R7      ! V4      pWë8X  g   Q h RRR4       \        P                  ! \        4      ;_uu_ 4        \        RV ^R7      ;_uu_ 4         RRR4       RRR4       RRR4       RRR4       VP                  pVP                  V8X  g   Q hVP                  V8X  g   Q hVP                  pWW43 F
  p^ Vn
        K  	  \        4       ;_uu_ 4       w  rÆ\	        VR,          V R7      ;_uu_ 4       p\        4       oWV3 F"  pVP                  VR	R
7      S\        V4      &   K$  	  V UU	U
u. uFj  w  r‰p
VP                  ! V.V3R lV	 4       O5/ \        V3R lV
P                  4        4       4      BR\!        \#        4       4      /B P%                  4       NKl  	  pp	pp
VV8X  g   Q h RRR4       RRR4       VP                  pVP                  V8X  g   Q hVP                  V8X  g   Q hVV8X  g   Q h\&        ;QJ d1    . R \(        P*                  P-                  R4       4       F  NK  	  5M*! R \(        P*                  P-                  R4       4       4      pVR8  d   VP                  V^,           8X  g   Q hR# VP                  V8X  g   Q hR# u upi u up
p	pi   + '       g   i     EL›; i  + '       g   i     ELl; i  + '       g   i     ELx; i  + '       g   i     EL„; i  + '       g   i     EL�; iu up
p	pi   + '       g   i     ELi; i  + '       g   i     ELu; i)c              3   ó8   "  € T F  p\        V4      x € K  	  R # 5ir2   )rÙ   rV   s   & r/   rY   Ú&test_manual_scatter.<locals>.<genexpr>  s   é € Ð7©h¨”/ !×$Ð$«hùó   ‚)rò   ró   rO   rP   r   )rS   Úscatter)r§   N)rS   rQ   rù   T)Ú	broadcastc              3   óZ   <"  € T F   pSP                  \        V4      V4      x € K"  	  R # 5ir2   ©r(   Úid)rW   ÚargÚ	scattereds   & €r/   rY   r÷   :  s#   øé € ÐB¹T°c�i—m‘m¤B s£G¨S×1Ð1»Tùs   ƒ(+c              3   ób   <"  € T F$  w  rVSP                  \        V4      V4      3x € K&  	  R # 5ir2   rü   )rW   ÚkeyÚvaluerÿ   s   &  €r/   rY   r÷   ;  s.   øé € ð á,:™L˜Sð ˜iŸm™m¬B¨u«I°uÓ=Õ>Û,:ùs   ƒ,/r  c              3   ó8   "  € T F  p\        V4      x € K  	  R # 5ir2   )rv   )rW   r.   s   & r/   rY   r÷   M  s   é € ÐSÑ0R¨1¤ A§ Ó0Rùrø   Ú.)iç  é   )r`   r   rô   r   r   r   r
   ra   rb   Ú	TypeErrorrÛ   Údictrù   rý   Úsubmitr)   Ústrr	   ÚresultÚtupler   Ú__version__Úsplit)rQ   rJ   rŸ   r    Úzr¬   rn   r¹   Úfuncr4   r5   Úexpectedrc   rG   Úresults_parallelÚ%n_serialization_scatter_with_parallelÚn_serialization_with_parallelÚvarÚobjÚresults_nativeÚn_serialization_scatter_nativeÚdistributed_versionrÿ   s   &                     @r/   Ú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ÖCÜ#+°qÕ#9¸%Ó#@Ð Ø'Ô3Ð3Ñ3÷ Dô —’œy×)Õ)Ü$¨V¸$È×JÖ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´×0GÑ0G×0MÑ0MÈcÔ0RÓSÓSÐØ˜YÔ&ð
 �w‰wÐ7¸!Õ;Ô;Ð;Ò;à�w‰wÐ7Ô7Ð7Ò7ùòG 6ùô G÷ D×CÐCú÷ K×JÐJú÷ *×)Ð)ú÷ -×,Ð,ú÷ 
�ˆüô:÷	 -×,Ð,ú÷ 
�ˆús®   ³M9Á7M>Â OÂ?O	ÃNÃ3*O	ÄN-Ä4NÄ6N-Ä>O	ÅOÆ8PÇ;O0	ÈA0O)ÊO0	ÊPÎNÎ	O	ÎN*Î$	N-Î-N>Î8	O	ÏOÏ	OÏO&	Ï)O0	Ï0PÏ;	PÐP	c                 óØ  a	€ \         P                  ! R 4      pVP                  ! \        R4      VP                  R7      o	VP                  ! \        R4      VP                  R7      pS	.^,          V.^,          ,           p\        4       ;_uu_ 4       w  pw  rV\        VR,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ! R \        V4       4       4       RRR4       \        R	V4      pW…R,          ,          W†R,          ,          ,           ^8X  g   Q h RRR4       RRR4       \        4       ;_uu_ 4       w  pw  rV\        VR,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ! V	3R
 l\        ^4       4       4       RRR4       \        R	V4      pW…R,          ,          ^ 8X  g   Q hW†R,          ,          ^ 8X  g   Q h RRR4       RRR4       R#   + '       g   i     EL; i  + '       g   i     Lì; i  + '       g   i     L÷; i  + '       g   i     L•; i  + '       g   i     Lg; i  + '       g   i     R# ; i)r¾   rp   rˆ   rO   rP   r   rR   c              3   óT   "  € T F  w  r\        \        4      ! W"WR 7      x € K   	  R# 5i))ÚoptN©r   r6   )rW   rX   r‹   s   &  r/   rY   Ú$test_auto_scatter.<locals>.<genexpr>f  s'   é € ð á#=™˜ô œD”M $¨a×:Ñ:Û#=ùs   ‚&(NrÊ   c              3   ó^   <"  € T F"  p\        \        4      ! SR ,          V4      x € K$  	  R# 5i):Nr^   NNr  )rW   rX   Údata1s   & €r/   rY   r  s  s#   øé € ÐIÁ¸1œ7¤4œ=¨¨r­°A×6Ð6Ãùs   ƒ*-)ra   rÎ   r“   rv   r”   r   r   r   r
   Ú	enumeraterM   r`   )
Úloop_in_threadr   Údata2Údata_to_processrc   rd   re   rG   rÕ   r   s
   &        @r/   Ú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Õ6¸&Ü ¨×0Ö0ô ”
ñ ä#,¨_Ô#=óô ÷ 1ô "Ð"8¸&ÓAˆFØ˜I�,Õ'¨&°9µÕ*>Õ>À!ÔCÐCÑC÷ 7÷ 
ô 
�Œ‘k�q™&˜1Ü�A�i•L ~×6Õ6¸&Ü ¨×0Ö0Ü”
ÔIÄÀaÄÓIÔI÷ 1ô "Ð"8¸&ÓAˆFØ˜I�,Õ'¨1Ô,Ð,Ð,Ø˜I�,Õ'¨1Ô,Ð,Ñ,÷ 7÷ 
‰÷ 1×0Ð0ú÷ 7×6ú÷ 
�ú÷" 1×0ú÷ 7×6ú÷ 
�ˆúsy   Â"HÂ3H	Ã!G8Ã)>H	Ä(HÅ
"IÅ,I	Æ$H2Æ%A I	Ç&IÇ8H	È	H	ÈHÈHÈH/	È2IÈ=I	ÉIÉIÉI)	Úretry_noc                 ó  aaa	a
a€ \         P                  ! R 4      o
^
o^
pV
3R lo	VV	3R lo\        4       ;_uu_ 4       w  pw  rE\        VR,          V R7      ;_uu_ 4       p\	        RR7      ;_uu_ 4        S
P
                  ! R4      o\        4       ! VV3R l\        V4       4       4      pR	R	R	4       R	R	R	4       R	R	R	4       R	#   + '       g   i     L"; i  + '       g   i     L-; i  + '       g   i     R	# ; i)
r¾   c                 ó(   <€ SP                   ! V 4      # r2   )rÐ   )rŸ   rX   Újr   s   &&&€r/   Úmy_sumÚ#test_nested_scatter.<locals>.my_sum‚  s   ø€ Ø�vŠv�a‹yÐr7   c                 óÜ   <a a€ \        4       p\        R R7      ;_uu_ 4        \        4       ! V VV3R l\        S4       4       4      pRRR4       \	        X4      #   + '       g   i     L; i)r   rR   c              3   óP   <"  € T F  p\        S4      ! SVR  SV4      x € K  	  R # 5ir2   rl   )rW   r)  ÚarrayrX   r*  s   & €€€r/   rY   ÚEtest_nested_scatter.<locals>.outer_function_joblib.<locals>.<genexpr>ˆ  s+   øé € ð !Ù:P°Q”˜”  a b 	¨1¨a×0Ð0Ó:Pùs   ƒ#&N)r   r   r
   r`   rÐ   )r.  rX   rG   ÚresultsÚNUM_INNER_TASKSr*  s   ff  €€r/   Úouter_function_joblibÚ2test_nested_scatter.<locals>.outer_function_joblib…  sM   ú€ Ü“ˆÜ V×,Ö,Ü”jö !Ü:?ÀÔ:Pó!ó ˆG÷ -ô �7‹|Ð÷	 -×,ús   ¢&AÁA+	rO   rP   r   rR   i'  c              3   óN   <"  € T F  p\        S4      ! SVR  V4      x € K  	  R # 5ir2   rl   )rW   rX   Úmy_arrayr2  s   & €€r/   rY   Ú&test_nested_scatter.<locals>.<genexpr>‘  s.   øé € ð á3˜ô Ð1Ô2°8¸A¸B°<À×CÐCÛ3ùó   ƒ"%N)ra   rÎ   r   r   r   r“   r
   r`   )rQ   r&  ÚNUM_OUTER_TASKSrc   rd   re   rn   r1  r5  r*  r   r2  s   &&     @@@@@r/   Útest_nested_scatterr9  {  s¬   ü€ ä	×	Ò	˜WÓ	%€Bà€OØ€Oõöô 
�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö0ØŸ7š7 5›>�Ü”Jõ ä" ?Ô3óó �÷ 1÷ -÷ 
‰ç0×0ú÷ -×,ú÷ 
�ˆús;   ¿"C-Á!C	Á67CÂ-C	Â5C-ÃCÃC	ÃC*Ã%C-Ã-C>	c                 ó:  a€ R  o\        4       ;_uu_ 4       w  pw  r#\        VR,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        ^R7      ! V3R l\	        ^
4       4       4      pV F  p\        \        V4      4      ^8:  d   K  Q h	  RRR4       RRR4       \        VR,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        ^R7      ! V3R l\	        ^
4       4       4      pV F  p\        \        V4      4      ^8:  d   K  Q h	  RRR4       RRR4       RRR4       R#   + '       g   i     L­; i  + '       g   i     L¸; i  + '       g   i     LH; i  + '       g   i     LS; i  + '       g   i     R# ; i)	c            	      óÀ   € \        \        ^R7      ! R \        ^4       4       4      4      p V \        \        ^R7      ! R \        ^4       4       4      4      ,          p V # )r|   ©rx   c              3   ó^   "  € T F#  p\        \        P                  4      ! 4       x € K%  	  R # 5ir2   ©r   r&   Úgetpidrm   s   & r/   rY   ÚOtest_nested_backend_context_manager.<locals>.get_nested_pids.<locals>.<genexpr>™  s   é € Ð%MÁH¸q¤g¬b¯i©iÔ&8×&:Ð&:ÃHùó   ‚+-c              3   ó^   "  € T F#  p\        \        P                  4      ! 4       x € K%  	  R # 5ir2   r>  rm   s   & r/   rY   r@  š  s   é € Ð&NÁXÀ¤w¬r¯y©yÔ'9×';Ð';ÃXùrA  )Úsetr
   r`   )Úpidss    r/   Ú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ˆØˆr7   rO   rP   r   rR   r<  c              3   óD   <"  € T F  p\        S4      ! 4       x € K  	  R # 5ir2   rl   ©rW   rn   rE  s   & €r/   rY   Ú6test_nested_backend_context_manager.<locals>.<genexpr>   ó   øé € ð 0Ù8A°1”G˜OÔ,×.Ð.»	ùó   ƒ Nc              3   óD   <"  € T F  p\        S4      ! 4       x € K  	  R # 5ir2   rl   rH  s   & €r/   rY   rI  ©  rJ  rK  )r   r   r   r
   r`   rD   rC  )r"  rc   rd   re   rG   Ú
pid_groupsÚ	pid_grouprE  s   &      @r/   Ú#test_nested_backend_context_managerrO  —  s$  ø€ òô
 
�Œ‘k�q™&˜1Ü�A�i•L ~×6Õ6¸&Ü ¨×0Ö0Ü%¨QÕ/ô 0Ü8=¸b¼	ó0ó �
ó ",�IÜœs 9›~Ó.°!Ö3Ð3Ð3ñ ",÷	 1÷ 7ô �A�i•L ~×6Õ6¸&Ü ¨×0Ö0Ü%¨QÕ/ô 0Ü8=¸b¼	ó0ó �
ó ",�IÜœs 9›~Ó.°!Ö3Ð3Ð3ñ ",÷	 1÷ 7÷ 
‰ç0×0ú÷ 7×6ú÷ 1×0ú÷ 7×6ú÷ 
�ˆúsx   —"F	¹E	ÁAD=ÂD=ÂE	Â $F	ÃE6	ÃAE#ÄE#Ä#E6	Ä+F	Ä=EÅE	ÅE ÅF	Å#E3Å.E6	Å6FÆF	Æ	F	c                 ód  a	a
€ R  o	V	3R lo
\        4       ;_uu_ 4       w  pw  r#\        VR,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ;_uu_ 4       pS	! V4      R8X  g   Q hVP                  R	8X  g   Q hV! V
3R l\        ^4       4       4      pRRR4       X F  w  rxVR8X  g   Q hVR	8X  d   K  Q h	  RRR4       RRR4       RRR4       R#   + '       g   i     LG; i  + '       g   i     L5; i  + '       g   i     L@; i  + '       g   i     R# ; i)
c                 óB   € V P                   P                  P                  # r2   )rr   Ú	__class__rè   )Úps   &r/   Ú_backend_typeÚJtest_nested_backend_context_manager_implicit_n_jobs.<locals>._backend_type´  s   € Ø�z‰z×#Ñ#×,Ñ,Ð,r7   c                  óŽ   <€ \        4       ;_uu_ 4       p S! V 4      V P                  3uuR R R 4       #   + '       g   i     R # ; ir2   )r
   rx   )rS  rT  s    €r/   Úget_nested_implicit_n_jobsÚWtest_nested_backend_context_manager_implicit_n_jobs.<locals>.get_nested_implicit_n_jobs·  s)   ø€ Ü�ZŒZ˜1Ù  Ó# Q§X¡XÐ-÷ �Z�Z‹Zús	   ”3³A	rO   rP   r   rR   r   c              3   óD   <"  € T F  p\        S4      ! 4       x € K  	  R # 5ir2   rl   )rW   rn   rW  s   & €r/   rY   ÚFtest_nested_backend_context_manager_implicit_n_jobs.<locals>.<genexpr>Á  s    øé € ð *ÙGOÀ!œÐ :Ô;×=Ð=ÃxùrK  Néÿÿÿÿ)r   r   r   r
   rx   r`   )rQ   rc   rd   re   rG   rS  Úall_nested_n_jobsÚbackend_typeÚnested_n_jobsrT  rW  s   &        @@r/   Ú3test_nested_backend_context_manager_implicit_n_jobsr_  °  sí   ù€ ò-õ.ô 
�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨×0Ö0Ü—Z”Z 1Ù(¨Ó+Ð/GÔGÐGÐGØŸ8™8 rœ>Ð)˜>Ù()ô *ÜGLÈQÄxó*ó )Ð%÷  ó 4EÑ/�LØ'Ð+CÔCÐCÐCØ(¨BÖ.Ð.Ð.ñ 4E÷ 1÷ -÷ 
‰÷  —Zú÷ 1×0ú÷ -×,ú÷ 
�ˆúsY   ž"DÁ D	ÁC8Á(>C%Â&C8ÃC8ÃD	ÃDÃ%C5Ã0C8Ã8DÄD	ÄDÄDÄD/	c           	      ó8  € \         P                  ! \        4      ;_uu_ 4       p\        R R7      ;_uu_ 4         RRR4       RRR4       R\	        XP
                  4      P                  4       9   g   Q hR#   + '       g   i     LD; i  + '       g   i     LO; i)r   rR   Nzcreate a dask client)ra   rb   r9   r   r	  r  Úlower)rQ   Úinfos   & r/   Útest_errorsrc  É  s^   € Ü	�Š”z×	"Ô	" dÜ V×,Ö,Ø÷ -÷ 
#ð "¤S¨¯©£_×%:Ñ%:Ó%<Ô<Ð<Ò<÷ -×,ú÷ 
#×	"ús!   £B	¸A6	ºB	Á6BÂB	Â	B	c                 óÞ  € \        4       ;_uu_ 4       w  pw  r#\        VR ,          V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        ^R7      ! R \	        ^4       4       4      p\        V^ ,          ^ ,          ^ ,          \        4      '       g   Q h RRR4       \        RR7      ;_uu_ 4        \        ^R7      ! R \	        ^4       4       4      p\        V^ ,          ^ ,          ^ ,          \        4      '       g   Q h RRR4       RRR4       RRR4       R#   + '       g   i     L�; i  + '       g   i     L5; i  + '       g   i     L@; i  + '       g   i     R# ; i)rO   rP   r   rR   r<  c              3   óN   "  € T F  p\        \        4      ! R R7      x € K  	  R # 5i)N©Únested_require©r   Úouterrm   s   & r/   rY   Ú.test_correct_nested_backend.<locals>.<genexpr>Ö  s   é € ð ,ÙAI¸A”GœE”N°$×7Ñ7Ãùó   ‚#%Nc              3   óN   "  € T F  p\        \        4      ! R R7      x € K  	  R# 5i)Ú	sharedmemrf  Nrh  rm   s   & r/   rY   rj  Ý  s   é € ð ,ÙHPÀ1”GœE”N°+×>Ñ>Ëùrk  )r   r   r   r
   r`   rs   r   r   )rQ   rc   rd   re   rG   r
  s   &     r/   Útest_correct_nested_backendrn  Ñ  sû   € Ü	�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°ä ¨×0Ö0Ü!¨Õ+ñ ,ÜAFÀqÄó,ó �ô " &¨¥)¨A¥,¨q¥/Ô3I×JÒJÐJÑJ÷	 1ô !¨×0Ö0Ü!¨Õ+ñ ,ÜHMÈaÌó,ó �ô " &¨¥)¨A¥,¨q¥/Ô3C×DÒDÐDÑD÷	 1÷ -÷ 
‰÷ 1×0ú÷ 1×0ú÷ -×,ú÷ 
�ˆúsT   “"EµE	Á
AD"ÂE	Â7AD5ÄE	ÄEÄ"D2Ä-E	Ä5EÅ E	ÅEÅEÅE,	c                 óP   a € \        ^RR7      ! V 3R l\        ^4       4       4      # )r|   Úthreads)rx   Úpreferc              3   óN   <"  € T F  p\        \        4      ! S4      x € K  	  R # 5ir2   )r   Úmiddle)rW   rn   rg  s   & €r/   rY   Úouter.<locals>.<genexpr>ä  s    øé € ð 0Ù19¨AŒ”Œ˜×'Ð'³ùr7  ©r
   r`   rf  s   fr/   ri  ri  ã  s(   ø€ Ü˜1 YÕ/ô 0Ü16°q´ó0ó ð r7   c                 óH   € \        ^V R7      ! R \        ^4       4       4      # )r|   )rx   Úrequirec              3   óJ   "  € T F  p\        \        4      ! 4       x € K  	  R # 5ir2   )r   Úinnerrm   s   & r/   rY   Úmiddle.<locals>.<genexpr>ê  s   é € Ð.RÉÀA¬w´u¬~×/?Ð/?Ëùr�   ru  )rw  s   &r/   rs  rs  é  s   € Ü˜1 gÕ.Ñ.RÌÈqÌÓ.RÓRÐRr7   c                  ó*   € \        4       P                  # r2   )r
   rr   r3   r7   r/   ry  ry  í  s   € Ü‹:×ÑÐr7   c           
      ó  € \        V R RR7      ;_uu_ 4        \        RR7      ;_uu_ 4        \        ^R7      ! R \        ^4       4       4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)FT)rQ   Ú	processesÚset_as_defaultr   rR   r<  c              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   )r   rý   rV   s   & r/   rY   Ú0test_secede_with_no_processes.<locals>.<genexpr>õ  s   é € Ð@±x°!œw¤rœ{¨1Ÿ~˜~³xùr\   N)r   r   r
   r`   rP   s   &r/   Útest_secede_with_no_processesr�  ñ  sU   € ä	�T U¸4×	@Ö	@Ü V×,Ö,Ü˜AÕÑ@´u¸Q´xÓ@Ô@÷ -÷ 
AÑ	@ß,×,ú÷ 
A×	@Ð	@ús"   —A4¬#A!	ÁA4Á!A1Á,A4Á4B	c                 ó0   € ^ RI Hp V! 4       P                  # )r   )Ú
get_worker)r   rƒ  rO   )rn   rƒ  s   & r/   Ú_worker_addressr„  ø  s   € Ý&á‹<×ÑÐr7   c                 óž  € \        4       ;_uu_ 4       w  pw  r#\        VR ,          V R7      ;_uu_ 4       p\        RVR ,          R7      ;_uu_ 4        \        4       ! R \	        ^
4       4       4      pWRR ,          .^
,          8X  g   Q h RRR4       \        RVR ,          R7      ;_uu_ 4        \        4       ! R \	        ^
4       4       4      pWSR ,          .^
,          8X  g   Q h RRR4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     L5; i  + '       g   i     L@; i  + '       g   i     R# ; i)rO   rP   r   )rS   Úworkersc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   ©r   r„  rV   s   & r/   rY   Ú-test_dask_backend_keywords.<locals>.<genexpr>  ó   é € Ð PÁiÀ¤¬Ô!9¸!×!<Ð!<Ãiùr\   Nc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rˆ  rV   s   & r/   rY   r‰    rŠ  r\   rž   )rQ   rc   rd   re   rG   rf   s   &     r/   Útest_dask_backend_keywordsrŒ  þ  sÞ   € Ü	�Œ‘k�q™&˜1Ü�A�i•L t×,Õ,°Ü ¨¸¸9½×FÖFÜ”jÑ PÄeÈBÄiÓ PÓP�Ø �|˜n¨rÕ1Ô1Ð1Ñ1÷ Gô !¨¸¸9½×FÖFÜ”jÑ PÄeÈBÄiÓ PÓP�Ø �|˜n¨rÕ1Ô1Ð1Ñ1÷ G÷ -÷ 
‰çF×Fú÷ G×Fú÷ -×,ú÷ 
�ˆúsR   “"D;µD(	Á8DÂ$D(	Â/8DÃ(D(	Ã0D;ÄDÄD(	ÄD%Ä D(	Ä(D8Ä3D;Ä;E	c           
      óÞ  € \        R V R7      ;_uu_ 4       p\        RR7      ;_uu_ 4        \        4       ! R \        ^
4       4       4       RRR4       \	        4       pVP
                  P                  P                  '       d&   \        R4       \	        4       V^,           8  d   KI  Q hVP                  '       d   Q h RRR4       R#   + '       g   i     L„; i  + '       g   i     R# ; i)F)r}  rQ   r   rR   c              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   Ú/test_scheduler_tasks_cleanup.<locals>.<genexpr>  ó   é € Ð:±	¨1”wœs”| A—�³	ùr\   Ng{®Gáz„?)
r   r   r
   r`   r   r   Ú	schedulerr¹   r   Úfutures)rQ   rG   Ústarts   &  r/   Útest_scheduler_tasks_cleanupr”  
  s›   € Ü	˜% d×	+Õ	+¨vÜ V×,Ö,ÜŒJÑ:´°b´	Ó:Ô:÷ -ô “ˆØ�n‰n×&Ñ&×,×,Ð,Ü�$ŒKÜ“6˜E A�IÖ%Ð%Ð%à—>—>�>Ð!Ð!�>÷ 
,Ñ	+ß,×,ú÷ 
,×	+Ð	+ús4   –C«!C	Á7CÂCÂ'CÂ;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                 óÒ  € \        ^ R^R7      p\        V4      pV R8X  d   VP                  ! ^ ^R7       MV R8X  d   VP                  ! ^4        \	        RR7      ;_uu_ 4        \        4       ! R \        ^
4       4       4       R	R	R	4       VP                  4        VP                  ! 4        R	#   + '       g   i     L3; i  TP                  4        TP                  ! 4        i ; i)
r   F©r~   r}  r   r–  )ÚminimumÚmaximumr—  r   rR   c              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   Ú(test_wait_for_workers.<locals>.<genexpr>+  r�  r\   N)r   r   ÚadaptÚscaler   r
   r`   rÒ   )r•  r   rG   s   &  r/   Útest_wait_for_workersr¡    s¤   € ô  Q°%ÈAÔN€GÜ�G‹_€FØ˜:Ô%Ø�Š˜a¨Ö+Ø	˜^Ô	+ð
 	�Š�aÔðÜ V×,Ö,ô ŒJÑ:´°b´	Ó:Ô:÷ -ð
 	�‰ŒØ�ŠŽ÷ -×,ûð
 	�‰ŒØ�Š�ús$   ÁC Á$!B0ÂC Â0C 	Â;C Ã#C&c            
      ó  € \        ^ R^R7      p \        V 4      p \        RRR7      ;_uu_ 4        Rp\        P                  ! \
        VR7      ;_uu_ 4        \        4       ! R \        ^
4       4       4       R	R	R	4       R	R	R	4       \        R^ R7      ;_uu_ 4        R
p\        P                  ! \        VR7      ;_uu_ 4        \        4       ! R \        ^
4       4       4       R	R	R	4       R	R	R	4       VP                  4        V P                  ! 4        R	#   + '       g   i     L¨; i  + '       g   i     L³; i  + '       g   i     La; i  + '       g   i     Ll; i  TP                  4        T P                  ! 4        i ; i)r   Frš  r   gš™™™™™¹?)rS   Úwait_for_workers_timeoutz7DaskDistributedBackend has no worker after 0.1 seconds.)Úmatchc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   Ú0test_wait_for_workers_timeout.<locals>.<genexpr>:  ó   é € Ð>±I¨qœ7¤3œ<¨Ÿ?˜?³Iùr\   Nz+DaskDistributedBackend has no active workerc              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   r¦  @  r§  r\   )
r   r   r   ra   rb   ÚTimeoutErrorr
   r`   ÚRuntimeErrorrÒ   )r   rG   Úmsgs      r/   Útest_wait_for_workers_timeoutr¬  1  só   € ä Q°%ÈAÔN€GÜ�G‹_€FðÜ VÀc×JÖJàKˆCÜ—’œ|°3×7Ö7Ü”
Ñ>´E¸"´IÓ>Ô>÷ 8÷ Kô  VÀa×HÖHà?ˆCÜ—’œ|°3×7Ö7Ü”
Ñ>´E¸"´IÓ>Ô>÷ 8÷ Ið 	�‰ŒØ�ŠŽ÷ 8×7ú÷ K×Jú÷ 8×7ú÷ I×Hûð 	�‰ŒØ�Š�úsj   ›E$ °'D+Á!D	Á8D+Â E$ Â'EÃ!D>	Ã%EÃ-E$ ÄD(Ä#D+Ä+D;	Ä6E$ Ä>EÅ	EÅE!	ÅE$ Å$#FrS   ÚlokyÚmultiprocessingc                 óÄ  a € \        ^R7      p\        V4      p V 3R lpVP                  V4      pVP                  4       p\	        V4      ^8X  g   Q hV^ ,          P
                  p\        V\        4      '       g   Q hR\        V4      9   g   Q h VP                  ^R7       VP                  ! ^R7       R#   TP                  ^R7       TP                  ! ^R7       i ; i)r|   )r~   c                  óÆ   <€ \         P                  ! R R7      ;_uu_ 4       p \        ^SR7      ! R \        ^
4       4       4       RRR4       V #   + '       g   i     X # ; i)T)Úrecord)rx   rS   c              3   óL   "  € T F  p\        \        4      ! V4      x € K  	  R # 5ir2   rU   rV   s   & r/   rY   Ú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\   N)ÚwarningsÚcatch_warningsr
   r`   )r±  rS   s    €r/   Úfunc_using_joblib_parallelÚStest_joblib_warning_inside_dask_daemonic_worker.<locals>.func_using_joblib_parallelL  sN   ø€ ô
 ×(Ò(°×5Õ5¸Ü ¨7Õ3Ñ3WÌUÐSUÌYÓ3WÔW÷ 6ð ˆM÷ 6Ö5ð ˆMús   ¡$AÁA 	zdistributed.worker.daemonrÌ   N)
r   r   r  r
  rD   Úmessagers   ÚUserWarningr	  rÒ   )rS   r   rG   r¶  Úfutr±  Úwarnings   f      r/   Ú/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   šA6B8 Â8'C)gš™™™™™©?r[  )r   r   )PÚ
__future__r   r   r   r&   r´  r   r   r   Úuuidr	   ra   Ú r
   r   r   r   Ú_daskr   rt   r   r   Úcommonr   r   Útest_parallelr   r   r   rÎ   r   r   r   r   r   Údistributed.metricsÚdistributed.utils_testr   r   r   Úfixturer0   r6   r<   rM   rg   rw   ÚmarkÚparametrizer€   r†   r—   r™   r¡   r»   r×   ÚobjectrÙ   rô   r  r%  rE   r`   r9  rO  r_  rc  rn  ri  rs  ry  r�  r„  rŒ  r”  Úskipifr  r¡  r¬  r¼  r3   r7   r/   Ú<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ÐN¨;×+BÑ+BÀhÑ+NØLð ó ñó	ó Kð
ò*ð* ‡�×Ñ˜ VÐ->Ð$?Ó@ñ"ó Aò"r7   