
    i
                     >    d dl mZ d dlmZmZ  G d de          ZdS )    )absolute_import)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                 r    t          t          |                               ||           |j        | _        d S N)superr   start_reactor)self	scheduleralias	__class__s      m/var/www/html/crypto-mining-system/backend/venv/lib/python3.11/site-packages/apscheduler/executors/twisted.pyr   zTwistedExecutor.start   s1    ot$$**9e<<<!*    c                       fd} j                                                             |t          j        | j        j                   d S )Nc                     | r                     j        |           d S                     j        |j        |j                   d S r	   )_run_job_successid_run_job_errorvaluetb)successresultjobr   s     r   callbackz0TwistedExecutor._do_submit_job.<locals>.callback   sN     E%%cff55555##CFFL&)DDDDDr   )r   getThreadPoolcallInThreadWithCallbackr   _jobstore_alias_loggername)r   r   	run_timesr   s   ``  r   _do_submit_jobzTwistedExecutor._do_submit_job   st    	E 	E 	E 	E 	E 	E 	##%%>>gsC$7DLDU	W 	W 	W 	W 	Wr   )__name__
__module____qualname____doc__r   r$   __classcell__)r   s   @r   r   r      sX         + + + + +W W W W W W Wr   r   N)
__future__r   apscheduler.executors.baser   r   r    r   r   <module>r-      sm    & & & & & & < < < < < < < <W W W W Wl W W W W Wr   