U nj+@s|ddlmZmZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZmZmZmZmZejZGdddZd S) )IterableMapping)timezone)isclassismethod)uuid4) BaseTrigger)check_callable_argsconvert_to_datetime datetime_reprget_callable_name obj_to_ref ref_to_objcseZdZdZdZd fdd ZddZdd Zd d Zd d Z ddZ e ddZ ddZ ddZddZddZddZddZddZZS)!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_timetriggerNc s6t||_d|_|jfd|p(tji|dS)Nr)super__init__rr_modifyrhex)selfZ schedulerrr __class__3/tmp/pip-unpacked-wheel-giblih11/apscheduler/job.pyr =s z Job.__init__cKs|jj|j|jf||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 )rZ modify_jobrr)r#changesr&r&r'modifyCs z Job.modifycKs|jj|j|j|f||S)z Shortcut for switching the trigger on this job. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.reschedule_job` :return Job: this job instance )rZreschedule_jobrr)r#rZ trigger_argsr&r&r' rescheduleQs zJob.reschedulecCs|j|j|j|S)z Temporarily suspend the execution of this job. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.pause_job` :return Job: this job instance )rZ pause_jobrrr#r&r&r'pause_s z Job.pausecCs|j|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 )rZ resume_jobrrr+r&r&r'resumeks z Job.resumecCs|j|j|jdS)z Unschedules this job and removes it from its associated job store. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.remove_job` N)rZ remove_jobrrr+r&r&r'removewsz Job.removecCs |jdkS)z{ Returns ``True`` if the referenced job is still waiting to be added to its designated job store. N)rr+r&r&r'pendingsz Job.pendingcCs@g}|j}|r<|t|tkr<|||j||}q |S)z Computes the scheduled run times between ``next_run_time`` and ``now`` (inclusive). :type now: datetime.datetime :rtype: list[datetime.datetime] )r astimezoneUTCappendrZget_next_fire_time)r#nowZ run_timesrr&r&r'_get_run_timess  zJob._get_run_timesc Ks0i}d|krB|d}t|ts(tdt|dr:td||d<d|ks\d|ks\d|krd|krn|dn|j}d|kr|dn|j}d|kr|dn|j}t|tr|}t |}n8t |rz t |}Wqtk rd}YqXntdt|d s| d ddkrt ||d <t|ts6t|ts>td t|tsVt|ts^td t|||||d<||d <||d<||d<d |kr|d }|rt|tstd ||d <d|kr|d}|dk rt|tr|dkrtd||d<d|kr$t|d}||d<d|kr^|d}t|trN|dkrVtd||d<d|kr|d}t|tstd|jjd||d<d|kr|d}t|tstd||d<d|kr|d}t||jjd|d<|r tdd||D]\} }t|| |qdS)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)rrr+r&r&r'__repr__@sz Job.__repr__cCsBt|dr$|jrdt|jnd}nd}|jd|jd|dS)Nrz next run at: Zpausedr/z (trigger: r5))r:rr rr)r#statusr&r&r'__str__Cs z Job.__str__)N)r@ __module__ __qualname____doc__ __slots__r r)r*r,r-r.propertyr/r4r!rLrNrQrRrU __classcell__r&r&r$r'rs"    g$rN)collections.abcrrdatetimerinspectrruuidrZapscheduler.triggers.baserZapscheduler.utilr r r r r rutcr1rr&r&r&r's