+
    *Qj	                         ^ RI Ht ^ RIt^ RIHtHt  ^ RIHt  ! R R]4      t
 ! R R]
4      t ! R	 R
]
4      tR#   ]	 d    Rt L.i ; i)    )abstractmethodN)BaseExecutorrun_job)BrokenProcessPoolc                   L   a a ] tR t^t o]V 3R l4       tR tRR ltRtVt	V ;t
# )BasePoolExecutorc                8   < \         \        V `  4        Wn        R # N)superr   __init___pool)selfpool	__class__s   &&s/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/apscheduler/executors/pool.pyr   BasePoolExecutor.__init__   s    .0
    c                   a a VV 3R  lp S P                   P                  \        SSP                  VS P                  P
                  4      pVP                  V4       R#   \         d    S P                  P                  R4       S P                   P                  S P                   P                  4      S n         S P                   P                  \        SSP                  TS P                  P
                  4      p Li ; i)c                 F  < \        V R 4      '       d   V P                  4       M*V P                  4       \        V P                  4       RR4      3w  rV'       d   SP	                  SP
                  W4       R# SP                  SP
                  V P                  4       4       R# )exception_info__traceback__N)hasattrr   	exceptiongetattr_run_job_errorid_run_job_successresult)fexctbjobr   s   &  r   callback1BasePoolExecutor._do_submit_job.<locals>.callback   sq    -4Q8H-I-Iq'')wq{{}ot'TU C##CFFC4%%cffahhj9r   z<Process pool is broken; replacing pool with a fresh instanceN)r   submitr   _jobstore_alias_loggernamer   warningr   _max_workersadd_done_callback)r   r"   	run_timesr#   r   s   ff&  r   _do_submit_jobBasePoolExecutor._do_submit_job   s    	:	c

!!'30C0CYPTP\P\PaPabA 	
H% ! 	cLL  !_`--djj.E.EFDJ

!!'30C0CYPTP\P\PaPabA	cs   AA BC=<C=c                <    V P                   P                  V4       R # r
   )r   shutdown)r   waits   &&r   r0   BasePoolExecutor.shutdown$   s    

D!r   )r   )T)__name__
__module____qualname____firstlineno__r   r   r-   r0   __static_attributes____classdictcell____classcell__r   __classdict__s   @@r   r   r      s&      &$" "r   r   c                   :   a a ] tR t^(t oRtRV 3R lltRtVtV ;t# )ThreadPoolExecutora  
An executor that runs jobs in a concurrent.futures thread pool.

Plugin alias: ``threadpool``

:param max_workers: the maximum number of spawned threads.
:param pool_kwargs: dict of keyword arguments to pass to the underlying
    ThreadPoolExecutor constructor
c                   < T;'       g    / p\         P                  P                  ! \        V4      3/ VB p\        \        V `  V4       R # r
   )
concurrentfuturesr=   intr   r   r   max_workerspool_kwargsr   r   s   &&& r   r   ThreadPoolExecutor.__init__3   s@    !''R!!44S5EUU $06r    
   N	r3   r4   r5   r6   __doc__r   r7   r8   r9   r:   s   @@r   r=   r=   (   s     7 7r   r=   c                   :   a a ] tR t^9t oRtRV 3R lltRtVtV ;t# )ProcessPoolExecutora  
An executor that runs jobs in a concurrent.futures process pool.

Plugin alias: ``processpool``

:param max_workers: the maximum number of spawned processes.
:param pool_kwargs: dict of keyword arguments to pass to the underlying
    ProcessPoolExecutor constructor
c                   < T;'       g    / p\         P                  P                  ! \        V4      3/ VB p\        \        V `  V4       R # r
   )r?   r@   rL   rA   r   r   rB   s   &&& r   r   ProcessPoolExecutor.__init__D   s@    !''R!!55c+6FV+V!41$7r   rF   rG   rI   r:   s   @@r   rL   rL   9   s     8 8r   rL   )abcr   concurrent.futuresr?   apscheduler.executors.baser   r   concurrent.futures.processr   ImportErrorr   r=   rL   rF   r   r   <module>rT      sT      <<
"| "87) 7"8* 8c  s   = 	A	A	