+
    *Qj                     ^    ^ RI Ht ^ RIt^ RIHtHt ^ RIHt ^ RIH	t	 R t
 ! R R]4      tR# )	    )absolute_importN)wrapspartial)BaseScheduler)	maybe_refc                 0   a  \        S 4      V 3R  l4       pV# )c                 ^   < \        SV .VO5/ VB pV P                  P                  V4       R # N)r   
_eventloopcall_soon_threadsafe)selfargskwargswrappedfuncs   &*, w/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/apscheduler/schedulers/asyncio.pywrapper"run_in_event_loop.<locals>.wrapper
   s+    $6t6v6,,W5    )r   )r   r   s   f r   run_in_event_loopr   	   s     
4[6 6 Nr   c                      a a ] tR t^t oRtRtRtRV 3R llt]RV 3R ll4       t	V 3R lt
R tR t]R 4       tR	 tR
tVtV ;t# )AsyncIOSchedulera  
A scheduler that runs on an asyncio (:pep:`3156`) event loop.

The default executor can run jobs based on native coroutines (``async def``).

Extra options:

============== =============================================================
``event_loop`` AsyncIO event loop to use (defaults to the global event loop)
============== =============================================================
Nc                   < V P                   '       g   \        P                  ! 4       V n         \        \        V `  V4       R # r
   )r   asyncioget_event_loopsuperr   start)r   paused	__class__s   &&r   r   AsyncIOScheduler.start!   s,    %446DO+F3r   c                N   < \         \        V `  V4       V P                  4        R # r
   )r   r   shutdown_stop_timer)r   waitr   s   &&r   r"   AsyncIOScheduler.shutdown'   s    .t4r   c                n   < \        VP                  R R4      4      V n        \        \        V `  V4       R# )
event_loopN)r   popr   r   r   
_configure)r   configr   s   &&r   r)   AsyncIOScheduler._configure,   s*    #FJJ|T$BC08r   c                    V P                  4        Ve-   V P                  P                  WP                  4      V n        R # R # r
   )r#   r   
call_laterwakeup_timeoutr   wait_secondss   &&r   _start_timerAsyncIOScheduler._start_timer0   s3    # OO66|[[QDM $r   c                f    V P                   '       d   V P                   P                  4        V = R # R # r
   )r/   cancel)r   s   &r   r#   AsyncIOScheduler._stop_timer5   s%    ===MM  " r   c                h    V P                  4        V P                  4       pV P                  V4       R # r
   )r#   _process_jobsr2   r0   s   & r   r.   AsyncIOScheduler.wakeup:   s*    ))+,'r   c                    ^ RI Hp V! 4       # )r   )AsyncIOExecutor)apscheduler.executors.asyncior;   )r   r;   s   & r   _create_default_executor)AsyncIOScheduler._create_default_executor@   s    A  r   )r   r/   )F)T)__name__
__module____qualname____firstlineno____doc__r   r/   r   r   r"   r)   r2   r#   r.   r=   __static_attributes____classdictcell____classcell__)r   __classdict__s   @@r   r   r      s]     
 JH4  9R

 ( (
! !r   r   )
__future__r   r   	functoolsr   r   apscheduler.schedulers.baser   apscheduler.utilr   r   r    r   r   <module>rM      s%    &  $ 5 &1!} 1!r   