i{ ddlZddlZddlmZddlmZddlmZm Z GddeZ Gdde Z Gd d e Z dS) N)abstractmethod)BrokenProcessPool) BaseExecutorrun_jobc<eZdZefdZdZddZxZS)BasePoolExecutorcVt||_dSN)super__init___pool)selfpool __class__s a/home/ubuntu/.hermes/hermes-agent/venv/lib/python3.11/site-packages/apscheduler/executors/pool.pyr zBasePoolExecutor.__init__ s$  cfd}jtj|jj}||dS)Nc^t|dr|n6|t|ddf\}}|rj||dSj|dS)Nexception_info __traceback__)hasattrr exceptiongetattr_run_job_errorid_run_job_successresult)fexctbjobrs rcallbackz1BasePoolExecutor._do_submit_job..callbacks1.//T  """kkmmWQ[[]]OT%R%RS C  :##CFC44444%%cfahhjj99999r)r submitr_jobstore_alias_loggernameadd_done_callback)rr! run_timesr"rs`` r_do_submit_jobzBasePoolExecutor._do_submit_jobsj : : : : : : J   S#-y$,:K   H%%%%%rTc:|j|dSr )r shutdown)rwaits rr+zBasePoolExecutor.shutdown s D!!!!!r)T)__name__ __module__ __qualname__rr r)r+ __classcell__rs@rrr se^&&&"""""""""rrc$eZdZdZdfd ZxZS)ThreadPoolExecutora An executor that runs jobs in a concurrent.futures thread pool. Plugin alias: ``threadpool`` :param max_workers: the maximum number of spawned threads. :param pool_kwargs: dict of keyword arguments to pass to the underlying ThreadPoolExecutor constructor Nc|pi}tjjt|fi|}t |dSr ) concurrentfuturesr3intr r r max_workers pool_kwargsrrs rr zThreadPoolExecutor.__init__/sN!'R !4S5E5EUUUU rr4N)r-r.r/__doc__r r0r1s@rr3r3$sGrr3c.eZdZdZdfd ZfdZxZS)ProcessPoolExecutora# An executor that runs jobs in a concurrent.futures process pool. Plugin alias: ``processpool`` :param max_workers: the maximum number of spawned processes. :param pool_kwargs: dict of keyword arguments to pass to the underlying ProcessPoolExecutor constructor r4Nc|pi|_|jdtjdt jjt|fi|j}t |dS)N mp_contextspawn) r; setdefaultmultiprocessing get_contextr6r7r?r8r r r9s rr zProcessPoolExecutor.__init__@s&," ##L/2Mg2V2VWWW!5     $ 0   rc6 t||dS#t$rg|jd|jj|jjfi|j|_t||YdSwxYw)NzrNs888888<<<<<<<<"""""|"""6)"33333*33333r