df+ddlmZmZddlmZddlZddlmZddlm Z m Z m Z m Z m Z mZmZ ddlmZmZGddeZy#e$r ddlmZmZYwxYw) )ismethodisclass)uuid4N) BaseTrigger) ref_to_obj obj_to_ref datetime_repr repr_escapeget_callable_namecheck_callable_argsconvert_to_datetime)IterableMappingceZdZdZdZdfd ZdZdZdZdZ dZ e d Z d Z d Zd Zd ZdZdZdZdZxZS)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. ) _scheduler_jobstore_aliasidtriggerexecutorfuncfunc_refargskwargsnamemisfire_grace_timecoalesce max_instances next_run_time __weakref__c tt| ||_d|_|j dd|xst ji|y)Nr)superr__init__rr_modifyrhex)self schedulerrr __class__s H/home/api-vastappli/venv/lib/python3.12/site-packages/apscheduler/job.pyr$z Job.__init__-s@ c4!### 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.modify3s. #""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.rescheduleAs1 '&&tww0D0Dg^Q]^ 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.pauseMs' !!$''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.resumeYs' ""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.removees" ""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.pendingns##t++r+cg}|j}|r:||kr5|j||jj||}|r||kr5|S)z Computes the scheduled run times between ``next_run_time`` and ``now`` (inclusive). :type now: datetime.datetime :rtype: list[datetime.datetime] )rappendrget_next_fire_time)r'now run_timesrs r*_get_run_timeszJob._get_run_times{sV **   4   ] + LL;;M3OM  4r+c i}d|vrR|jd}t|tjs t dt |dr t d||d<d|vs d|vsd|vred|vr|jdn |j}d|vr|jdn |j}d|vr|jdn |j}t|tjr|}t|}n#t|r t|}n t dt |d s |jd dt||d <t|tjst|ts t d t|tjst|t s t d t#|||||d<||d <||d<||d<d |vr=|jd }|rt|tjs t d ||d <d|vrB|jd}|*t|tj$r|dkr t d||d<d|vrt'|jd}||d<d|vr@|jd}t|tj$r|dkr t d||d<d|vrH|jd}t|t(s"t d|j*j,z||d<d|vr;|jd}t|tjs t d||d<d|vr5|jd}t/||j0j2d|d<|rt5ddj7|ztj8|D]\} }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$ 0 01!$'$$)$/H  WXX4(W[[-F-N"3D"9$ 0 01D(9S DEE&#"2"23:fg;V CDD dF 3#HV #+HZ #HV !'HX  W KK'E 5#2B2B C @AA$HV  7 *KK 45E *UC'$--"8Z=MQUQ^Q^=^MM#eDII&66D99D''MM|| kkII"&"9"9 !//!//  r+c`|jdddkDrtd|dz|d|_|d|_t |j|_|d|_|d|_|d|_|d |_ |d |_ |d |_ |d |_ |d |_ |d|_y)Nr^r]z5Job has version %s, but only version 1 can be handledrrrrrrrrrrr)rPrNrrrrrrrrrrrrr)r'states r* __setstate__zJob.__setstate__ s 99Y "Q &T"9-./ /+f  t}}- Y' j) &M Ho &M "'(<"=j) "?3"?3r+c`t|tr|j|jk(StSN)rIrrNotImplemented)r'others r*__eq__z Job.__eq__s% eS !77ehh& &r+c`dt|jdt|jdS)Nz )r rrr6s r*__repr__z Job.__repr__!s*5dgg*> DII@VWWr+c4t|jSrf)r __unicode__r6s r*__str__z Job.__str__$s4++-..r+ct|dr'|jrdt|jznd}nd}|jd|jd|dS)Nrz next run at: pausedr?z (trigger: rG))rMrr rr)r'statuss r*rmzJob.__unicode__'sN 4 )((& d6H6H(II.6 F*.))T\\6JJr+rf)rS __module__ __qualname____doc__ __slots__r$r/r3r7r:r=propertyr?rEr%rardrirkrnrm __classcell__)r)s@r*rrsn.1I5    B,, ^&@ >4$ X/Kr+r)inspectrruuidrrJapscheduler.triggers.baserapscheduler.utilrrr r r r r collections.abcrr ImportError collectionsobjectrr"r+r*rsO% 1.1 ]K&]K .--.sA AA