
    i                        S SK Jr  S SKrS SKrS SKrS SKJrJrJrJ	r	  S SK
JrJr  S SKr\R                  S:  a  S SK
Jr  OS SKJr  \" S5      r\" S5      rSS	 jrSS
 jr " S S\5      rSS jr    SS jrg)    )annotationsN)AsyncIterator	CoroutineIterableIterator)CallableTypeVar)   
   )	ParamSpecPTc            
     P  ^#    [         R                  " S[        5        [        R                  " 5        IS h  vN mSU4S jjnU  H,  u  p#TR                  U[        R                  " U40 UD65        M.     S S S 5      IS h  vN   g  NO N! , IS h  vN  (       d  f       g = f7f)NzOrun_until_first_complete is deprecated and will be removed in a future version.c                d   >#    U " 5       I S h  vN   TR                   R                  5         g  N7fN)cancel_scopecancel)func
task_groups    ]/var/www/html/qgis-automation/mouza_env/lib/python3.13/site-packages/starlette/concurrency.pyrun%run_until_first_complete.<locals>.run   s&     &LL##**, s   0. 0)r   zCallable[[], Coroutine]returnNone)warningswarnDeprecationWarninganyiocreate_task_group
start_soon	functoolspartial)argsr   r   kwargsr   s       @r   run_until_first_completer%      sr     MMY
 &&((J	- !LD!!#y'8'8'H'HI ! )(((((sD   5B&BB&;B7B&B
B&
B&B#BB#B&c                   #    [         R                  " U /UQ70 UD6n [        R                  R	                  U 5      I S h  vN $  N7fr   )r!   r"   r   	to_threadrun_sync)r   r#   r$   s      r   run_in_threadpoolr)   $   s:     T3D3F3D))$////s   =AA Ac                      \ rS rSrSrg)_StopIteration)    N)__name__
__module____qualname____firstlineno____static_attributes__r-       r   r+   r+   )   s    r3   r+   c                B     [        U 5      $ ! [         a    [        ef = fr   )nextStopIterationr+   )iterators    r   _nextr8   -   s&    H~ s   
 c                  #    [        U 5      n  [        R                  R                  [        U5      I S h  vN 7v   M2   N	! [
         a     g f = f7fr   )iterr   r'   r(   r8   r+   )r7   as_iterators     r   iterate_in_threadpoolr<   7   sK      x.K
	00DDD D 		s7   A'A AA AA 
AAAA)r#   ztuple[Callable, dict]r   r   )r   zCallable[P, T]r#   zP.argsr$   zP.kwargsr   r   )r7   zIterator[T]r   r   )r7   zIterable[T]r   zAsyncIterator[T])
__future__r   r!   sysr   collections.abcr   r   r   r   typingr   r	   anyio.to_threadr   version_infor   typing_extensionsr   r   r%   r)   	Exceptionr+   r8   r<   r-   r3   r   <module>rE      st    "  
  H H $ w +cNCLJ 0
	Y 	r3   