
    Owg                     *    d dl mZmZ  G d de      Zy)    )BaseExecutorrun_jobc                   (     e Zd ZdZ fdZd Z xZS )TwistedExecutorzP
    Runs jobs in the reactor's thread pool.

    Plugin alias: ``twisted``
    c                 H    t         |   ||       |j                  | _        y N)superstart_reactor)self	scheduleralias	__class__s      T/var/www/horilla/myenv/lib/python3.12/site-packages/apscheduler/executors/twisted.pyr
   zTwistedExecutor.start   s    i'!**    c                       fd} j                   j                         j                  |t        j                  | j
                  j                         y )Nc                     | rj                  j                  |       y j                  j                  |j                  |j                         y r   )_run_job_successid_run_job_errorvaluetb)successresultjobr   s     r   callbackz0TwistedExecutor._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_jobzTwistedExecutor._do_submit_job   sC    	E 	##%>>gsC$7$7DLLDUDU	
r   )__name__
__module____qualname____doc__r
   r#   __classcell__)r   s   @r   r   r      s    +	
r   r   N)apscheduler.executors.baser   r   r    r   r   <module>r+      s    <
l 
r   