Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/flask_apscheduler/__pycache__/scheduler.cpython-39.pyc
Ðазад
a t�h�3 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZ dd lmZmZ e�d �ZG d d � d e�ZdS ) zAPScheduler implementation.� N)� EVENT_ALL)�BackgroundScheduler)�JobLookupError)� make_response� )�api)� fix_job_def� pop_triggerZflask_apschedulerc @ s: e Zd ZdZdCdd�Zedd� �Zedd� �Zed d � �Zed d � �Z ed d� �Z dd� Z dDdd�Z dEdd�Z dd� Zdd� Zefdd �Zd d � Zd d � ZdFd!d"�ZdGd#d$�ZdHd%d&�ZdId'd(�ZdJd)d*�ZdKd+d,�ZdLd-d.�ZdMd/d0�ZdNd1d2�Z dOd3d4�Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$dS )P� APSchedulerz)Provides a scheduler integrated to Flask.Nc C sX |pt � | _t�� �� | _d | _dg| _d | _d| _ d| _ d| _ d | _ |rT| � |� d S )N�*Fz /schedulerz scheduler.)r � _scheduler�socket� gethostname�lower� _host_name�_authentication_callback� allowed_hosts�auth� api_enabled� api_prefix�endpoint_prefix�app�init_app)�self� schedulerr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/flask_apscheduler/scheduler.py�__init__# s zAPScheduler.__init__c C s | j S )zGet the host name.)r �r r r r � host_name2 s zAPScheduler.host_namec C s | j jS )z*Get true whether the scheduler is running.)r �runningr r r r r 7 s zAPScheduler.runningc C s | j jS )z Get the state of the scheduler.)r �stater r r r r! < s zAPScheduler.statec C s | j S )zGet the base scheduler.)r r r r r r A s zAPScheduler.schedulerc C s | j jS )z Get the base scheduler decorator)r Z scheduled_jobr r r r �taskF s zAPScheduler.taskc C s0 || _ | | j _| �� | �� | jr,| �� dS )z=Initialize the APScheduler with a Flask application instance.N)r Z apscheduler� _load_config� _load_jobsr � _load_api)r r r r r r K s zAPScheduler.init_appFc C sH | j | jvr6d| jvr6t�d| j d�| j�f � dS | jj|d� dS )z~ Start the scheduler. :param bool paused: if True, don't start job processing until resume is called. r zIHost name %s is not allowed to start the APScheduler. Servers allowed: %s�,N)�paused)r r �LOGGER�debug�joinr �start)r r' r r r r+ W s �zAPScheduler.startTc C s | j �|� dS )a Shut down the scheduler. Does not interrupt any currently running jobs. :param bool wait: ``True`` to wait until all currently executing jobs have finished :raises SchedulerNotRunningError: if the scheduler has not been started yet N)r �shutdown)r �waitr r r r, c s zAPScheduler.shutdownc C s | j �� dS )z� Pause job processing in the scheduler. This will prevent the scheduler from waking up to do job processing until :meth:`resume` is called. It will not however stop any already running job processing. N)r �pauser r r r r. m s zAPScheduler.pausec C s | j �� dS )z9 Resume job processing in the scheduler. N)r �resumer r r r r/ v s zAPScheduler.resumec C s | j �||� dS )a Add a listener for scheduler events. When a matching event occurs, ``callback`` is executed with the event object as its sole argument. If the ``mask`` parameter is not provided, the callback will receive events of all types. For further info: https://apscheduler.readthedocs.io/en/latest/userguide.html#scheduler-events :param callback: any callable that takes one argument :param int mask: bitmask that indicates which events should be listened to N)r � add_listener)r �callback�maskr r r r0 | s zAPScheduler.add_listenerc C s | j �|� dS )z; Remove a previously added event listener. N)r �remove_listener)r r1 r r r r3 � s zAPScheduler.remove_listenerc K sD t |�}||d< ||d< |�d�p$||d< t|� | jjf i |��S )a Add the given job to the job list and wakes up the scheduler if it's already running. :param str id: explicit identifier for the job (for modifying it later) :param func: callable (or a textual reference to one) to run at the given time �id�func�name)�dict�getr r �add_job)r r4 r5 �kwargsZjob_defr r r r9 � s zAPScheduler.add_jobc C s t �dt� | �||� dS )z� DEPRECATED, use remove_job instead. Remove a job, preventing it from being run any more. :param str id: the identifier of the job :param str jobstore: alias of the job store that contains the job z7delete_job has been deprecated, use remove_job instead.N)�warnings�warn�DeprecationWarning� remove_job�r r4 �jobstorer r r � delete_job� s zAPScheduler.delete_jobc C s t �dt� | �|� dS )z� DEPRECATED, use remove_all_jobs instead. Remove all jobs from the specified job store, or all job stores if none is given. :param str|unicode jobstore: alias of the job store zAdelete_all_jobs has been deprecated, use remove_all_jobs instead.N)r; r< r= �remove_all_jobs�r r@ r r r �delete_all_jobs� s zAPScheduler.delete_all_jobsc C s | j �||� dS )z� Remove a job, preventing it from being run any more. :param str id: the identifier of the job :param str jobstore: alias of the job store that contains the job N)r r> r? r r r r> � s zAPScheduler.remove_jobc C s | j �|� dS )z� Remove all jobs from the specified job store, or all job stores if none is given. :param str|unicode jobstore: alias of the job store N)r rB rC r r r rB � s zAPScheduler.remove_all_jobsc C s | j �||�S )a$ Return the Job that matches the given ``id``. :param str id: the identifier of the job :param str jobstore: alias of the job store that most likely contains the job :return: the Job by the given ID, or ``None`` if it wasn't found :rtype: Job )r �get_jobr? r r r rE � s zAPScheduler.get_jobc C s | j �|�S )z� Return a list of pending jobs (if the scheduler hasn't been started yet) and scheduled jobs, either from a specific job store or from all of them. :param str jobstore: alias of the job store :rtype: list[Job] )r �get_jobsrC r r r rF � s zAPScheduler.get_jobsc K sJ t |� d|v r4t|�\}}| jj|||fi |�� | jj||fi |��S )z� Modify the properties of a single job. Modifications are passed to this method as extra keyword arguments. :param str id: the identifier of the job :param str jobstore: alias of the job store that contains the job �trigger)r r r Zreschedule_job� modify_job)r r4 r@ �changesrG Z trigger_argsr r r rH � s zAPScheduler.modify_jobc C s | j �||� dS )z� Pause the given job until it is explicitly resumed. :param str id: the identifier of the job :param str jobstore: alias of the job store that contains the job N)r � pause_jobr? r r r rJ � s zAPScheduler.pause_jobc C s | j �||� dS )z� Resume the schedule of the given job, or removes the job if its schedule is finished. :param str id: the identifier of the job :param str jobstore: alias of the job store that contains the job N)r � resume_jobr? r r r rK � s zAPScheduler.resume_jobc C s2 | j �||�}|st|��|j|ji |j�� dS )z� Run the given job without scheduling it. :param id: the identifier of the job. :param str jobstore: alias of the job store that contains the job :return: N)r rE r r5 �argsr: )r r4 r@ �jobr r r �run_job s zAPScheduler.run_jobc C s || _ |S )z� A decorator that is used to register a function to authenticate a user. :param func: The callback to authenticate. )r )r r5 r r r � authenticate s zAPScheduler.authenticatec C s� t � }| jj�d�}|r ||d< | jj�d�}|r:||d< | jj�d�}|rT||d< | jj�d�}|rn||d< | jjf i |�� | jj�d | j�| _| jj�d | j�| _| jj�d | j�| _| jj�d | j�| _| jj�d | j �| _ | jj�d| j �| _ dS )zF Load the configuration from the Flask configuration. ZSCHEDULER_JOBSTORESZ jobstoresZSCHEDULER_EXECUTORS� executorsZSCHEDULER_JOB_DEFAULTS� job_defaultsZSCHEDULER_TIMEZONE�timezoneZSCHEDULER_AUTHZSCHEDULER_VIEWS_ENABLEDZSCHEDULER_API_ENABLEDZSCHEDULER_API_PREFIXZSCHEDULER_ENDPOINT_PREFIXZSCHEDULER_ALLOWED_HOSTSN) r7 r �configr8 r � configurer r r r r )r �optionsZ job_storesrP rQ rR r r r r# s( zAPScheduler._load_configc C sB | j j�d�}|s | j j�d�}|r>|D ]}| jf i |�� q(dS )zH Load the job definitions from the Flask configuration. ZSCHEDULER_JOBSZJOBSN)r rS r8 r9 )r �jobsrM r r r r$ = s zAPScheduler._load_jobsc C s� | � ddtjd� | � ddtjd� | � ddtjd� | � d dtjd� | � d dtjd � | � d dtjd � | � ddtjd� | � ddtj d� | � ddtj d� dS )z7 Add the routes for the scheduler API. �get_scheduler_info� �GETr9 z/jobs�POSTrE z/jobs/<job_id>rF rA �DELETE� update_job�PATCHrJ z/jobs/<job_id>/pauserK z/jobs/<job_id>/resumerN z/jobs/<job_id>/runN) �_add_url_router rW r9 rE rF rA r\ rJ rK rN r r r r r% J s zAPScheduler._load_apic C s@ | j r| j | }| jr | j| }| jj||| �|�|gd� dS )z� Add a Flask route. :param str endpoint: The endpoint name. :param str rule: The endpoint url. :param view_func: The endpoint func :param str method: The http method. )�methodsN)r r r Z add_url_rule� _apply_auth)r Zendpoint�rule� view_func�methodr r r r^ X s �zAPScheduler._add_url_routec s t ���� �fdd��}|S )z� Apply decorator to authenticate the user who is making the request. :param view_func: The flask view func. c sT � j s�| i |��S � j �� }|d u r.� �� S � jr>� �|�sF� �� S �| i |��S )N)r �get_authorization� _handle_authentication_errorr )rL r: Z auth_data�r rb r r � decoratedr s z*APScheduler._apply_auth.<locals>.decorated)� functools�wraps)r rb rg r rf r r` m s zAPScheduler._apply_authc C s" t d�}| j�� |jd< d|_|S )z1 Return an authentication error. z Access DeniedzWWW-Authenticatei� )r r Zget_authenticate_header�headers� status_code)r �responser r r re � s z(APScheduler._handle_authentication_error)NN)F)T)N)N)N)N)N)N)N)N)N)N)%�__name__� __module__� __qualname__�__doc__r �propertyr r r! r r" r r+ r, r. r/ r r0 r3 r9 rA rD r> rB rE rF rH rJ rK rN rO r# r$ r% r^ r` re r r r r r sJ r )rp rh �loggingr r; Zapscheduler.eventsr Z!apscheduler.schedulers.backgroundr Zapscheduler.jobstores.baser Zflaskr rX r �utilsr r � getLoggerr( �objectr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка