
    i                     *    S SK JrJr   " S S\5      rg)    )BaseExecutorrun_jobc                   2   ^  \ rS rSrSrU 4S jrS rSrU =r$ )TwistedExecutor   zD
Runs jobs in the reactor's thread pool.

Plugin alias: ``twisted``
c                 F   > [         TU ]  X5        UR                  U l        g N)superstart_reactor)self	scheduleralias	__class__s      J/app/mltbenv/lib/python3.13/site-packages/apscheduler/executors/twisted.pyr   TwistedExecutor.start   s    i'!**    c                    ^ ^ UU 4S jnT R                   R                  5       R                  U[        TTR                  UT R
                  R                  5        g )Nc                    > U (       a  TR                  TR                  U5        g TR                  TR                  UR                  UR                  5        g r	   )_run_job_successid_run_job_errorvaluetb)successresultjobr   s     r   callback0TwistedExecutor._do_submit_job.<locals>.callback   s8    %%cfff5##CFFFLL&))Dr   )r   getThreadPoolcallInThreadWithCallbackr   _jobstore_alias_loggername)r   r   	run_timesr   s   ``  r   _do_submit_jobTwistedExecutor._do_submit_job   sC    	E 	##%>>gsC$7$7DLLDUDU	
r   )r   )	__name__
__module____qualname____firstlineno____doc__r   r&   __static_attributes____classcell__)r   s   @r   r   r      s    +	
 	
r   r   N)apscheduler.executors.baser   r   r    r   r   <module>r1      s    <
l 
r   