+
    €",i}  ã                   ó–  € ^ RI t ^ RIt^ RIt^ RIt^ RIHtHtHtHtH	t	 ^ RI
HtHt ^ RIHt ^RIHtHt R t]P&                  P                   R 4       t]P&                  P                   R 4       t]]P&                  P                   R	 4       4       t]P&                  P                   R
 4       t]P&                  P                   R 4       tR# )é    N)ÚAsyncMemorizedFuncÚAsyncNotMemorizedFuncÚMemorizedResultÚMemoryÚNotMemorizedResult)ÚnpÚ
with_numpy)Úraises)Úcorrupt_single_cache_itemÚmonkeypatch_cached_func_warnc              ƒ  óø   "  € \        V^ R7      pVP                  V 4      p \        ^4       FF  p\        ^4       F4  pV ! V4      G Rj  x€L
 pWd8X  g   Q h\        V4      V^,           8X  d   K4  Q h	  KH  	  R#  L/5i)z<Similar to check_identity_lazy_async for coroutine functions©ÚlocationÚverboseN)r   ÚcacheÚrangeÚlen)ÚfuncÚaccumulatorr   ÚmemoryÚiÚ_Úvalues   &&&    Ú?/usr/lib/python3/dist-packages/joblib/test/test_memory_async.pyÚcheck_identity_lazy_asyncr      sj   é € ä˜X¨qÔ1€FØ�<‰<˜Ó€DÜ�1ŽXˆÜ�q–ˆAÙ˜q›'—MˆEØ”:Ð�:Ü�{Ó# q¨1¥uÖ,Ð,Ð,ó ó á!ùs   ‚AA:ÁA8Á	 A:Á.A:c           	   ƒ   óÞ  a	"  € \        4       o	V	3R  lp\        VS	V P                  4      G Rj  x€L
  R	 Fê  pR
 FŒ  p\        V P                  ^
VVR7      p\        P
                  ! V P                  RR7       VP                  V4      pV! ^4      G Rj  x€L
  VP                  RR7       \        S	4      pV! ^4      G Rj  x€L
 pKŽ  	  \        S	4      X^,           8X  g   Q hXP                  V^4      G Rj  x€L
 pVX8X  g   Q h\        S	4      V^,           8X  d   Kê  Q h	  RVn
        \        V P                  ^ R7      pVP                  V4      ! ^4      G Rj  x€L
  R#  EL4 LÐ L¥ Lp L5i)c              “   ór   <"  € \         P                  ! R 4      G Rj  x€L
  SP                  ^4       V #  L5i©gš™™™™™¹?N©ÚasyncioÚsleepÚappend)Únr   s   &€r   ÚfÚ(test_memory_integration_async.<locals>.f#   ó0   øé € Ü�mŠm˜CÓ × Ð Ø×Ñ˜1ÔØˆñ 	!ùó   ƒ7�5ž7NFT)r   r   Ú	mmap_modeÚcompress)Úignore_errors)ÚwarnÚ__main__r   )FT)ÚrN)Úlistr   Ústrpathr   ÚshutilÚrmtreer   Úclearr   ÚevalÚ
__module__)
Útmpdirr$   r)   r(   r   ÚgÚcurrent_accumulatorÚoutÚevaledr   s
   &        @r   Útest_memory_integration_asyncr:      sG  øé € ä“&€Kõô
 $ A {°F·N±NÓ
C×CÐCó "ˆÛ$ˆIÜØŸ™ØØ#Ø!ô	ˆFô �MŠM˜&Ÿ.™.¸Õ=Ø—‘˜Q“ˆAÙ�A“$�JˆJØ�G‰G˜ˆGÔÜ"% kÓ"2ÐÙ˜!›—*ŠCñ# %ô& �;ÓÐ#6¸Õ#:Ô:Ð:Ð:à—{‘{ 1 aÓ(×(ˆØ˜Œ}Ðˆ}Ü�;ÓÐ#6¸Õ#:Ö:Ð:Ð:ñ1 "ð8 €A„LÜ˜VŸ^™^°QÔ7€FØ
�,‰,�qŒ/˜!Ó
×ÒòC Dñ$ ñ ñ )ñ ùs^   ƒ+E-®E"¯A%E-ÂE%Â,E-ÃE'Ã6E-Ã8E)Ã9!E-Ä<E-ÅE+ÅE-Å%E-Å'E-Å)E-Å+E-c               ƒ   óü   a"  € \        4       oV3R  lp \        R^ R7      pVP                  V 4      p\        ^4       F7  p\	        S4      pV! ^4      G Rj  x€L
  \	        S4      V^,           8X  d   K7  Q h	  R#  L#5i)c              “   ór   <"  € \         P                  ! R 4      G Rj  x€L
  SP                  ^4       V #  L5ir   r   )Úxr   s   &€r   ÚffÚ test_no_memory_async.<locals>.ffP   r&   r'   Nr   )r.   r   r   r   r   )r>   r   Úggr   r7   r   s        @r   Útest_no_memory_asyncrA   L   sn   øé € ä“&€Kõô
 ˜T¨1Ô-€FØ	�‰�bÓ	€BÜ�1ŽXˆÜ! +Ó.ÐÙ�‹e�ˆÜ�;ÓÐ#6¸Õ#:Ö:Ð:Ð:ó áùs   ƒAA<ÁA:ÁA<Á4A<c              ƒ  óä  "  € \        V P                  R^ R7      pVP                  4       R 4       p\        P                  ! ^4      pV! V4      G Rj  x€L
 pV! V4      G Rj  x€L
 p\        V\        P                  4      '       g   Q hVP                  R8X  g   Q h\        V\        P                  4      '       g   Q hVP                  R8X  g   Q h??\        P                  ! 4        \        V4       \        W14      pV! V4      G Rj  x€L
 p\        V4      ^8X  g   Q hRp	W—^ ,          9   g   Q h\        V\        P                  4      '       g   Q hVP                  R8X  g   Q hR#  EL EL	 Ld5i)z8Check that mmap_mode is respected even at the first callr-   )r   r(   r   c              “   ó   "  € V ^,          # 5i)é   © )Úas   &r   ÚtwiceÚ6test_memory_numpy_check_mmap_mode_async.<locals>.twiced   s   é € à�1�uˆùs   ‚
NzException while loading results)r   r/   r   r   ÚonesÚ
isinstanceÚmemmapÚmodeÚgcÚcollectr   r   r   )
r5   Úmonkeypatchr   rG   rF   ÚbÚcÚrecorded_warningsÚdÚexception_msgs
   &&        r   Ú'test_memory_numpy_check_mmap_mode_asyncrU   ]   s3  é € ô
 ˜VŸ^™^°sÀAÔF€Fà‡\�\ƒ^ñó ðô 	�Š�‹
€AÙ�A‹h�€AÙ�A‹h�€Aä�aœŸ™×#Ò#Ð#Ð#Ø�6‰6�SŒ=Ðˆ=ä�aœŸ™×#Ò#Ð#Ð#Ø�6‰6�SŒ=Ðˆ=ð 	
Ø	Ü‡J‚J„LÜ˜fÔ%ô 5°UÓHÐÙ�A‹h�€AÜÐ Ó! QÔ&Ð&Ð&Ø5€MØ¨aÕ0Ô0Ð0Ð0ä�aœŸ™×#Ò#Ð#Ð#Ø�6‰6�SŒ=ÐŠ=ò3 	Úñ$ 	ùs8   ‚AE0ÁE(ÁE0Á"E+Á#B&E0Ä	E.Ä
AE0Å+E0Å.E0c           	   ƒ   ó˜  "  € RR lp\        \        WP                  4      \        V4      \	        V P                  ^ R7      P                  V4      \	        RR7      P                  V4      3\        \        \        \        34       Fª  w  r#\        ^4       FF  pVP                  ^4      G Rj  x€L
 p\        WS4      '       g   Q hVP                  4       ^8X  d   KF  Q h	  XP                  4        \        \        4      ;_uu_ 4        VP                  4        RRR4       VP                  4        K¬  	  R#  Lˆ  + '       g   i     L(; i5i)é   c              “   ój   "  € \         P                  ! R 4      G Rj  x€L
  V ^,          V,           #  L5ir   )r    r!   )r=   Úys   &&r   r$   Ú%test_call_and_shelve_async.<locals>.f‡   s)   é € Ü�mŠm˜CÓ × Ð Ø�!�t�a�xˆñ 	!ùs   ‚3œ1�3r   N)r   )rW   )Úzipr   r/   r   r   r   r   r   r   Úcall_and_shelverJ   Úgetr2   r
   ÚKeyError)r5   r$   r   ÚResultr   Úresults   &     r   Útest_call_and_shelve_asyncra   …   s÷   é € ôô
 ä˜q§.¡.Ó1Ü! !Ó$Ü˜FŸN™N°AÔ6×<Ñ<¸QÓ?Ü˜DÔ!×'Ñ'¨Ó*ð		
ô ÜÜÜð		
ö‰ˆô �q–ˆAØ×/Ñ/°Ó2×2ˆFÜ˜f×-Ò-Ð-Ð-Ø—:‘:“< 1Ö$Ð$Ð$ñ ð
 	�‰ŒÜ”H×ÕØ�J‰JŒL÷ à�‰Žó-ñ 3÷
 ×üs0   ‚B*E
Â,D5Â-)E
Ã+E
ÄD7ÄE
Ä7EÅE
c              ƒ   ó:  "  € R  pV P                  VR.R7      p/ pV! ^V4      G Rj  x€L
 ^8X  g   Q hV! ^V4      G Rj  x€L
 ^8X  g   Q hVP                  ^V4      G Rj  x€L
 w  rEV^8X  g   Q R4       h\        V\        4      '       g   Q R4       hR#  Ll LV L75i)c              “   ó�   "  € \         P                  ! R 4      G Rj  x€L
  VP                  V ^ 4      ^,           W&   W,          #  L'5ir   )r    r!   r]   )r=   Úcounters   &&r   r>   Ú*test_memorized_func_call_async.<locals>.ff§   s;   é € Ü�mŠm˜CÓ × Ð Ø—[‘[  AÓ&¨Õ*ˆ‰
Ø�zÐñ 	!ùs   ‚AœA�(Ard   )ÚignoreNzf has not been called properlyz0Metadata are not returned by MemorizedFunc.call.)r   ÚcallrJ   Údict)r   r>   r@   rd   r=   Úmetas   &     r   Útest_memorized_func_call_asyncrj   ¥   sž   é € òð
 
�‰�b ) ˆÓ	-€Bà€GÙ�A�w“× 1Ô$Ð$Ð$Ù�A�w“× 1Ô$Ð$Ð$à—G‘G˜A˜wÓ'×'�G€AØ�Œ6Ð3Ð3Ó3ˆ6Ü�dœD×!Ò!ÐUÐ#UÓUÒ!ñ  Ùá'ùs3   ‚&B¨B©BÁ BÁ BÁ!BÁ"4BÂBÂB)r    rM   r0   ÚpytestÚjoblib.memoryr   r   r   r   r   Újoblib.test.commonr   r	   Újoblib.testingr
   Útest_memoryr   r   r   Úmarkr:   rA   rU   ra   rj   rE   ó    r   Ú<module>rr      sÍ   ðÛ Û 	Û ã ÷õ ÷ .Ý !ç Pò-ð ‡�×Ññ)ó ð)ðX ‡�×Ññ;ó ð;ð  Ø‡�×Ññ#ó ó ð#ðL ‡�×Ññó ðð> ‡�×ÑñVó òVrq   