o
    ³tÃh	  ã                   @   s\   d dl mZ d dlZd dlmZmZ zd dlZW n ey#   edƒ‚w G dd„ deƒZdS )é    )Úabsolute_importN)ÚBaseExecutorÚrun_jobz(GeventExecutor requires gevent installedc                   @   s   e Zd ZdZdd„ ZdS )ÚGeventExecutorz?
    Runs jobs as greenlets.

    Plugin alias: ``gevent``
    c                    s0   ‡ ‡fdd„}t  tˆ ˆ j|ˆjj¡ |¡ d S )Nc                    sT   z|   ¡ }W n ty    ˆjˆ jgt ¡ dd … ¢R Ž  Y d S w ˆ ˆ j|¡ d S )Né   )ÚgetÚBaseExceptionÚ_run_job_errorÚidÚsysÚexc_infoÚ_run_job_success)ÚgreenletÚevents©ÚjobÚself© úR/var/www/html/bot/env/lib/python3.10/site-packages/apscheduler/executors/gevent.pyÚcallback   s   &ÿz/GeventExecutor._do_submit_job.<locals>.callback)ÚgeventÚspawnr   Ú_jobstore_aliasÚ_loggerÚnameÚlink)r   r   Ú	run_timesr   r   r   r   Ú_do_submit_job   s   zGeventExecutor._do_submit_jobN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   r   r      s    r   )	Ú
__future__r   r   Úapscheduler.executors.baser   r   r   ÚImportErrorr   r   r   r   r   Ú<module>   s    ÿ