Qi+ddlmZmZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZmZmZmZmZej&ZGddZy ) )IterableMapping)timezone)isclassismethod)uuid4) BaseTrigger)check_callable_argsconvert_to_datetime datetime_reprget_callable_name obj_to_ref ref_to_objceZdZdZdZdfd ZdZdZdZdZ dZ e d Z d Z d Zd Zd ZdZdZdZxZS)Joba Contains the options given when scheduling callables and its current schedule and other state. This class should never be instantiated by the user. :var str id: the unique identifier of this job :var str name: the description of this job :var func: the callable to execute :var tuple|list args: positional arguments to the callable :var dict kwargs: keyword arguments to the callable :var bool coalesce: whether to only run the job once when several run times are due :var trigger: the trigger object that controls the schedule of this job :var str executor: the name of the executor that will run this job :var int misfire_grace_time: the time (in seconds) how much this job's execution is allowed to be late (``None`` means "allow the job to run no matter how late it is") :var int max_instances: the maximum number of concurrently executing instances allowed for this job :var datetime.datetime next_run_time: the next scheduled run time of this job .. note:: The ``misfire_grace_time`` has some non-obvious effects on job execution. See the :ref:`missed-job-executions` section in the documentation for an in-depth explanation. ) __weakref___jobstore_alias _schedulerargscoalesceexecutorfuncfunc_refidkwargs max_instancesmisfire_grace_timename next_run_timetriggerc t|||_d|_|jdd|xst j i|y)Nr)super__init__rr_modifyrhex)self schedulerrr __class__s :/app/.venv/lib/python3.12/site-packages/apscheduler/job.pyr$z Job.__init__=s> ## 4)egkk4V4c j|jj|j|jfi||S)a- Makes the given changes to this job and saves it in the associated job store. Accepted keyword arguments are the same as the variables on this class. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.modify_job` :return Job: this job instance )r modify_jobrr)r'changess r*modifyz Job.modifyCs. #""477D,@,@LGL r+c l|jj|j|j|fi||S)z Shortcut for switching the trigger on this job. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.reschedule_job` :return Job: this job instance )rreschedule_jobrr)r'r trigger_argss r* reschedulezJob.rescheduleQs8 '&& GGT))7 6B  r+cf|jj|j|j|S)z Temporarily suspend the execution of this job. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.pause_job` :return Job: this job instance )r pause_jobrrr's r*pausez Job.pause_s' !!$''4+?+?@ r+cf|jj|j|j|S)z Resume the schedule of this job if previously paused. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.resume_job` :return Job: this job instance )r resume_jobrrr6s r*resumez Job.resumeks' ""477D,@,@A r+cd|jj|j|jy)z Unschedules this job and removes it from its associated job store. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.remove_job` N)r remove_jobrrr6s r*removez Job.removews" ""477D,@,@Ar+c|jduS)z{ Returns ``True`` if the referenced job is still waiting to be added to its designated job store. N)rr6s r*pendingz Job.pendings##t++r+c2g}|j}|r|jt|jtkr[|j||jj ||}|r,|jt|jtkr[|S)z Computes the scheduled run times between ``next_run_time`` and ``now`` (inclusive). :type now: datetime.datetime :rtype: list[datetime.datetime] )r astimezoneUTCappendr get_next_fire_time)r'now run_timesrs r*_get_run_timeszJob._get_run_timess **  8 8 =PSAT T   ] + LL;;M3OM 8 8 =PSAT Tr+c "i}d|vrH|jd}t|ts tdt |dr t d||d<d|vs d|vsd|vrGd|vr|jdn |j }d|vr|jdn |j}d|vr|jdn |j}t|tr|}t|}n#t|r t|}n tdt |d s |jd dt||d <t|tst|ts td t|tst|ts td t!|||||d<||d <||d<||d<d |vr3|jd }|rt|ts td ||d <d|vr8|jd}| t|t"r|dkr td||d<d|vrt%|jd}||d<d|vr6|jd}t|t"r|dkr td||d<d|vrI|jd}t|t&s#td|j(j*d||d<d|vr1|jd}t|ts td||d<d|vr5|jd}t-||j.j0d|d<|r)t3dj5dj7||j9D]\} }t;|| |y#t $rd}YwxYw)z| Validates the changes to the Job and makes the modifications if and only if all of them validate. rzid must be a nonempty stringzThe job ID may not be changedrrrNz5func must be a callable or a textual reference to onerz"args must be a non-string iterablez!kwargs must be a dict-like objectrzname must be a nonempty stringrrz??tT" !@AA"HTN W ' 1X5H*0G*;7;;v&D*0G*;7;;v&D.6'.AW[[*t{{F$$!$'$$)$/H  WXX4(W[[-F-N"3D"9$$JtX,F DEE&#&j.I CDD dF 3#HV #+HZ #HV !'HX  W KK'E 5# 6 @AA$HV  7 *KK 45E *UC*@EQJR.3H) *  Z01E#(HZ g %KK0EeS)UaZ JKK(-H_ %  kk),Gg{378I8I8R8R7SS[\#*HY   KK +EeS) ;<<#(HZ g %KK0E(;t//)H_ %  HOOIIg&  #..*JC D#u %+S"$#H$s) M?? N Nc |jstd|jd|j}t|rQt |j s)rrr6s r*__repr__z Job.__repr__@s477)6$))B77r+ct|dr'|jrdt|jznd}nd}|jd|jd|dS)Nrz next run at: pausedr?z (trigger: rI))rNrr rr )r'statuss r*__str__z Job.__str__Cs\ 4 )%% -0B0B"CC  F))K ~RxqAAr+rg)rT __module__ __qualname____doc__ __slots__r$r/r3r7r:r=propertyr?rGr%rbrerjrlrq __classcell__)r)s@r*rrsi.I$5    B,, e&N" H4& 8 Br+rN)collections.abcrrdatetimerinspectrruuidrapscheduler.triggers.baser apscheduler.utilr r r r rrutcrBrr"r+r*rs7-%1llzBzBr+