Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/apscheduler/__pycache__/job.cpython-39.pyc
Ðазад
a k�h�+ � @ sj d dl mZmZ d dlmZmZ d dlmZ d dlm Z d dl m Z m Z m Z mZmZmZ G dd� d�ZdS ) � )�Iterable�Mapping)�isclass�ismethod)�uuid4)� BaseTrigger)�check_callable_args�convert_to_datetime� datetime_repr�get_callable_name� obj_to_ref� ref_to_objc s� e Zd ZdZdZd � fdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z e dd� �Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Z� ZS )!�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_alias�id�trigger�executor�func�func_ref�args�kwargs�name�misfire_grace_time�coalesce� max_instances� next_run_time� __weakref__Nc s6 t � �� || _d | _| jf d|p(t� ji|�� d S )Nr )�super�__init__r r �_modifyr �hex)�selfZ schedulerr r �� __class__� �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/apscheduler/job.pyr : s z Job.__init__c K s | j j| 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 Z modify_jobr r )r" �changesr% r% r& �modify@ s z Job.modifyc K s | j j| 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 )r Zreschedule_jobr r )r" r Z trigger_argsr% r% r& � rescheduleN s ��zJob.reschedulec C s | 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 )r Z pause_jobr r �r" r% r% r& �pause\ s z Job.pausec C s | 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 )r Z resume_jobr r r* r% r% r& �resumeh s z Job.resumec C s | j �| j| j� dS )z� Unschedules this job and removes it from its associated job store. .. seealso:: :meth:`~apscheduler.schedulers.base.BaseScheduler.remove_job` N)r Z remove_jobr r r* r% r% r& �removet s z Job.removec C s | j du S )z{ Returns ``True`` if the referenced job is still waiting to be added to its designated job store. N)r r* r% r% r& �pending} s z Job.pendingc C s4 g }| j }|r0||kr0|�|� | 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 �appendr Zget_next_fire_time)r" �nowZ run_timesr r% r% r& �_get_run_times� s zJob._get_run_timesc K s. i }d|v rB|� d�}t|t�s(td��t| d�r:td��||d< d|v s\d|v s\d|v �r�d|v rn|� d�n| j}d|v r�|� d�n| j}d|v r�|� d�n| j}t|t�r�|}t |�}n6t |�r�z t |�}W q� ty� d}Y q�0 ntd��t| d ��s |� d d�du �r t |�|d < t|t��s4t|t��s<td ��t|t��sTt|t��s\td ��t|||� ||d< ||d < ||d< ||d< d |v �r�|� d �}|�r�t|t��s�td ��||d < d|v �r|� d�}|du�r�t|t��r�|dk�r�td��||d< d|v �r"t|� d��}||d< d|v �r\|� d�}t|t��rL|dk�rTtd��||d< d|v �r�|� d�}t|t��s�td|jj� d���||d< d|v �r�|� d�}t|t��s�td��||d< d|v �r�|� d�}t|| jjd�|d< |�r td�d�|����|� � D ]\} }t | | |� �qdS ) z| Validates the changes to the Job and makes the modifications if and only if all of them validate. r z id must be a nonempty stringz The job ID may not be changedr r r Nz5func must be a callable or a textual reference to oner z"args must be a non-string iterablez!kwargs must be a dict-like objectr z name must be a nonempty stringr r z<misfire_grace_time must be either None or a positive integerr r z(max_instances must be a positive integerr z!Expected a trigger instance, got z insteadr zexecutor must be a stringr z6The following are not modifiable attributes of Job: {}�, ) �pop� isinstance�str� TypeError�hasattr� ValueErrorr r r r �callabler �getr r r r �int�boolr r$ �__name__r r �timezone�AttributeError�format�join�items�setattr) r" r' Zapproved�valuer r r r r �keyr% r% r& r � s� � � ���z Job._modifyc C s� | j std| j�d���| j}t|�rRt|j�sRt|�| j krR|jft| j� }n| j}d| j | j | j | j || j | j | j| j| j| jd� S )NzCThis Job cannot be serialized since the reference to its callable (z^) could not be determined. Consider giving a textual reference (module:function name) instead.� ) �versionr r r r r r r r r r r )r r8 r r r �__self__r �tupler r r r r r r r r r )r" r r r% r% r& � __getstate__ s4 ��� ��zJob.__getstate__c C s� |� dd�dkr$td|d � d���|d | _|d | _t| j�| _|d | _|d | _|d | _|d | _ |d | _ |d | _ |d | _ |d | _ |d | _d S )NrG rF zJob has version z#, but only version 1 can be handledr r r r r r r r r r r )r: r8 r r r r r r r r r r r r r )r" �stater% r% r& � __setstate__% s � zJob.__setstate__c C s t |t�r| j|jkS tS )N)r4 r r �NotImplemented)r" �otherr% r% r& �__eq__8 s z Job.__eq__c C s d| j � d| j� d�S )Nz <Job (id=z name=z)>)r r r* r% r% r& �__repr__= s z Job.__repr__c C sB t | d�r$| jr dt| j� nd}nd}| j� d| j� d|� d�S )Nr z next run at: Zpausedr. z (trigger: r2 �))r7 r r r r )r" �statusr% r% r& �__str__@ s ��z Job.__str__)N)r= � __module__� __qualname__�__doc__� __slots__r r( r) r+ r, r- �propertyr. r1 r rJ rL rO rP rS � __classcell__r% r% r# r& r s" g$r N)�collections.abcr r �inspectr r �uuidr Zapscheduler.triggers.baser Zapscheduler.utilr r r r r r r r% r% r% r& �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка