U
|
>7Le- ã @ sH d dl mZ d dlZd dlZd dlmZ d dlmZ G dd deZ dS )é )ÚIntervalTriggerN)ÚBackgroundScheduler)ÚRequestTaskSettingc @ sl e Zd ZdZddddZedddZd d
|
Zedd d Zdd dZ dd Z
|
dd Z dd Z dd Z dS )Ú TaskScheduleruF
|
ä»»å¡è°åº¦ç±»ï¼ç®¡çæ§å¶æ°æ®ç¬åä»»å¡æ§è¡æ¶æº
|
N)Úreturnc C s t | _d | _d S ©N)r Ú
|
_schedulerÚ_request_job_id©Úself© r úCe:\PycharmProject\fugitive_dust_new\src\scheduler\task_scheduler.pyÚ__init__ s zTaskScheduler.__init__)Úconfigc C s, d| _ | jj|d|j|j|j| j dd dS )u* æ ¹æ®ç¬åä»»å¡é
置信æ¯æ·»å ä»»å¡Z request_jobÚintervaliX )ÚsecondsÚ
|
start_dateÚend_dateÚidZmisfire_grace_timeN)r r Úadd_jobÚrequest_interval_secondsÚrequest_start_timeÚrequest_end_time)r Ú task_funcr r r r Úadd_task_by_config s ÿz TaskScheduler.add_task_by_configc C s | j dks| j | j ¡ dS )u 移é¤ä»»å¡N)r r Ú
|
remove_jobr
|
r r r r s
|
zTaskScheduler.remove_jobc C s. | j dkrdS | jj| j |j|j|jd dS )u* æ ¹æ®ç¬åä»»å¡é
置信æ¯ä¿®æ¹ä»»å¡N©r r r )r r Z
|
modify_jobr r r )r r r r r Úmodify_task_by_config s
|
ÿz#TaskScheduler.modify_task_by_configc C s | j j|d|||d dS )u æ·»å ä»»å¡r r N)r r )r r r Zintervelr r r r Úadd_task& s zTaskScheduler.add_taskc C s | j js| j ¡ dS )u å¼å§ä»»å¡N)r ÚrunningÚstartr
|
r r r Ú
|
start_task, s zTaskScheduler.start_taskc C s | j ¡ dS )u å
³éä»»å¡N)r Úshutdownr
|
r r r Ú shutdown_task1 s zTaskScheduler.shutdown_taskc C s | j d k S r )r r
|
r r r Úhas_request_job5 s z TaskScheduler.has_request_jobc C sV d}| j ¡ }tj ¡ jt d¡d}|D ]&}| |¡}t|dk}|dkr* qRq*|S )u6 å¤æå½å线ç¨å
çææå®æ¶ä»»å¡æ¯å¦å®æTÚUTC)Útzinfor F) r Zget_jobsÚdatetimeÚnowÚreplaceÚpytzÚtimezoneZ_get_run_timesÚlen)r ZfinishÚjobsr( ÚjÚtr r r Ú is_finish8 s
|
|
zTaskScheduler.is_finish)N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r r r r r! r# r$ r0 r r r r r s
|
r )
|
Z apscheduler.triggers.intervalr r' r* Z!apscheduler.schedulers.backgroundr Údb.models.tablesr Úobjectr r r r r Ú<module> s
|
|
