NhP+ @sddlmZmZddlmZddlZddlmZddlm Z m Z m Z m Z m Z mZmZyddlmZmZWn(ek rddlmZmZYnXGdddeZdS) )ismethodisclass)uuid4N) BaseTrigger) ref_to_obj obj_to_ref datetime_repr repr_escapeget_callable_namecheck_callable_argsconvert_to_datetime)IterableMappingcseZdZdZd/ZdfddZddZddZddZddZ ddZ e ddZ dd Z d!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.ZS)0Joba 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 :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_timeNc sHtt|j||_d|_|jd|p=tj|dS)Nr)superr__init__rr_modifyrhex)selfZ schedulerrr) __class__K/mod/web/acousticsspace/venv/lib/python3.5/site-packages/apscheduler/job.pyr-s  z Job.__init__cKs |jj|j|j||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%modify3s z Job.modifycKs#|jj|j|j|||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% rescheduleAs zJob.reschedulecCs|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 )rZ pause_jobrr)r"r$r$r%pauseMs z Job.pausecCs|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 )rZ resume_jobrr)r"r$r$r%resumeYs z Job.resumecCs|jj|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_jobrr)r"r$r$r%removeesz Job.removecCs |jdkS)z{ Returns ``True`` if the referenced job is still waiting to be added to its designated job store. N)r)r"r$r$r%pendingnsz Job.pendingcCsNg}|j}x8|rI||krI|j||jj||}qW|S)z Computes the scheduled run times between ``next_run_time`` and ``now`` (inclusive). :type now: datetime.datetime :rtype: list[datetime.datetime] )rappendrZget_next_fire_time)r"nowZ run_timesrr$r$r%_get_run_times{s   zJob._get_run_timesc Ksfi}d|krd|jd}t|tjs?tdt|drZtd||d)r rr)r"r$r$r%__repr__ sz Job.__repr__cCst|jS)N)r __unicode__)r"r$r$r%__str__#sz Job.__str__cCsQt|dr4|jr+dt|jnd}nd}d|j|j|fS)Nrz next run at: Zpausedr,z%s (trigger: %s, %s))r5rrrr)r"statusr$r$r%rN&s%zJob.__unicode__)z _schedulerz_jobstore_aliaszidztriggerzexecutorzfunczfunc_refzargszkwargsznamezmisfire_grace_timezcoalescez max_instancesz next_run_time)r; __module__ __qualname____doc__ __slots__rr'r(r)r*r+propertyr,r/r rGrIrLrMrOrNr$r$)r#r%rs&     `     r)inspectrruuidrr2Zapscheduler.triggers.baserZapscheduler.utilrrrr r r r collections.abcr r ImportError collectionsobjectrr$r$r$r%s 4