Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/apscheduler/jobstores/__pycache__/sqlalchemy.cpython-39.pyc
Ðазад
a k�h� � @ s� d dl Z d dlmZ d dlmZmZmZ d dlmZm Z m Z zHd dl m Z m Z mZmZmZmZmZmZmZ d dlmZ d dlmZ W n. ey� Z zed�e�W Y dZ[n dZ[0 0 G d d � d e�ZdS ) � N)�Job)� BaseJobStore�ConflictingIdError�JobLookupError)�datetime_to_utc_timestamp� maybe_ref�utc_timestamp_to_datetime) �Column�Float� LargeBinary�MetaData�Table�Unicode�and_� create_engine�select)�IntegrityError)�nullz0SQLAlchemyJobStore requires SQLAlchemy installedc s� e Zd ZdZddddejddf� fdd� Z� fdd�Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Z� ZS ) �SQLAlchemyJobStorea� Stores jobs in a database table using SQLAlchemy. The table will be created if it doesn't exist in the database. Plugin alias: ``sqlalchemy`` :param str url: connection string (see :ref:`SQLAlchemy documentation <sqlalchemy:database_urls>` on this) :param engine: an SQLAlchemy :class:`~sqlalchemy.engine.Engine` to use instead of creating a new one based on ``url`` :param str tablename: name of the table to store jobs in :param metadata: a :class:`~sqlalchemy.schema.MetaData` instance to use instead of creating a new one :param int pickle_protocol: pickle protocol level to use (for serialization), defaults to the highest available :param str tableschema: name of the (existing) schema in the target database where the table should be :param dict engine_options: keyword arguments to :func:`~sqlalchemy.create_engine` (ignored if ``engine`` is given) NZapscheduler_jobsc s� t � �� || _t|�p t� }|r.t|�| _n$|rJt|fi |p@i ��| _ntd��t||t dt d�dd�t dt d�dd�t d t d d �|d �| _ d S ) Nz%Need either "engine" or "url" defined�id� T)Z primary_key� next_run_time� )�index� job_stateF)Znullable)Zschema)�super�__init__�pickle_protocolr r �enginer � ValueErrorr r r r r �jobs_t)�self�urlr Z tablename�metadatar Z tableschemaZengine_options�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/apscheduler/jobstores/sqlalchemy.pyr 3 s �zSQLAlchemyJobStore.__init__c s" t � �||� | j�| jd� d S )NT)r �startr �creater )r! Z scheduler�aliasr$ r& r' r( S s zSQLAlchemyJobStore.startc C sl t | jjj��| jjj|k�}| j�� �0}|�|�� � }|rF| � |�nd W d � S 1 s^0 Y d S �N) r r �cr �wherer r �begin�execute�scalar�_reconstitute_job)r! �job_id� selectable� connectionr r& r& r' � lookup_jobW s z SQLAlchemyJobStore.lookup_jobc C s t |�}| �| jjj|k�S r+ )r � _get_jobsr r, r )r! �now� timestampr& r& r' � get_due_jobs] s z SQLAlchemyJobStore.get_due_jobsc C sv t | jjj��| jjjt� k��| jjj��d�}| j� � �&}|� |�� � }t |�W d � S 1 sh0 Y d S )N� ) r r r, r r- r �order_by�limitr r. r/ r0 r )r! r3 r4 r r& r& r' �get_next_run_timea s ���� z$SQLAlchemyJobStore.get_next_run_timec C s | � � }| �|� |S r+ )r6 Z_fix_paused_jobs_sorting)r! �jobsr& r& r' � get_all_jobsl s z SQLAlchemyJobStore.get_all_jobsc C s� | j �� jf i |jt|j�t�|�� | j �d���}| j � � �<}z|� |� W n t yj t|j��Y n0 W d � n1 s�0 Y d S )N)r r r )r �insert�valuesr r r �pickle�dumps� __getstate__r r r. r/ r r )r! �jobr@ r4 r& r& r' �add_jobq s �� zSQLAlchemyJobStore.add_jobc C s� | j �� jf i t|j�t�|�� | j�d���� | j j j |j k�}| j � � �.}|�|�}|jdkrlt|j ��W d � n1 s�0 Y d S )N)r r r )r �updaterA r r rB rC rD r r- r, r r r. r/ �rowcountr )r! rE rG r4 �resultr& r& r' � update_job s ���� z SQLAlchemyJobStore.update_jobc C sd | j �� �| j jj|k�}| j�� �,}|�|�}|jdkrBt |��W d � n1 sV0 Y d S )Nr ) r �deleter- r, r r r. r/ rH r )r! r2 rK r4 rI r& r& r' � remove_job� s z SQLAlchemyJobStore.remove_jobc C sB | j �� }| j�� �}|�|� W d � n1 s40 Y d S r+ )r rK r r. r/ )r! rK r4 r& r& r' �remove_all_jobs� s z"SQLAlchemyJobStore.remove_all_jobsc C s | j �� d S r+ )r Zdispose�r! r& r& r' �shutdown� s zSQLAlchemyJobStore.shutdownc C s: t �|�}| |d< t�t�}|�|� | j|_| j|_|S )NZjobstore)rB �loadsr �__new__� __setstate__Z _scheduler�_aliasZ_jobstore_alias)r! r rE r& r& r' r1 � s z$SQLAlchemyJobStore._reconstitute_jobc G s� g }t | jjj| jjj��| jjj�}|r8|�t|� �n|}t � }| j � � ��}|� |�D ]J}z|� | �|j�� W qX ty� | j�d|j� |�|j� Y qX0 qX|r�| j�� �| jjj�|��}|� |� W d � n1 s�0 Y |S )Nz)Unable to restore job "%s" -- removing it)r r r, r r r; r r- r �setr r. r/ �appendr1 � BaseExceptionZ_logger� exception�addrK �in_)r! � conditionsr> r3 Zfailed_job_idsr4 �rowrK r& r& r' r6 � s* � � �(z SQLAlchemyJobStore._get_jobsc C s d| j j� d| jj� d�S )N�<z (url=z)>)r% �__name__r r" rN r& r& r' �__repr__� s zSQLAlchemyJobStore.__repr__)r] � __module__� __qualname__�__doc__rB �HIGHEST_PROTOCOLr r( r5 r9 r= r? rF rJ rL rM rO r1 r6 r^ � __classcell__r& r& r$ r' r s, � r ) rB Zapscheduler.jobr Zapscheduler.jobstores.baser r r Zapscheduler.utilr r r Z sqlalchemyr r r r r r r r r Zsqlalchemy.excr Zsqlalchemy.sql.expressionr � ImportError�excr r& r& r& r' �<module> s ,
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка