r4i*ddlmZmZGddeZy)) BaseExecutorrun_jobc(eZdZdZfdZdZxZS)TwistedExecutorzP Runs jobs in the reactor's thread pool. Plugin alias: ``twisted`` cHt||||j|_yN)superstart_reactor)self scheduleralias __class__s i/mnt/ssd/data/python-lab/DaemonControl/venv/lib/python3.12/site-packages/apscheduler/executors/twisted.pyr zTwistedExecutor.start s  i'!** cfd}jjj|tj|j j y)Nc|rjj|yjj|j|jyr)_run_job_successid_run_job_errorvaluetb)successresultjobr s rcallbackz0TwistedExecutor._do_submit_job..callbacks8%%cfff5##CFFFLL&))Dr)r getThreadPoolcallInThreadWithCallbackr_jobstore_alias_loggername)r r run_timesrs`` r_do_submit_jobzTwistedExecutor._do_submit_jobsC E ##%>> gsC$7$7DLLDUDU r)__name__ __module__ __qualname____doc__r r# __classcell__)rs@rrrs +  rrN)apscheduler.executors.baserrrrrr+s< l r