Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/backends/database/__pycache__/__init__.cpython-39.pyc
Ðазад
a t�hG � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlm Z ddl m Z ddl m Z d d lmZmZmZ d d lmZ z dd lmZmZ dd lmZ W n ey� e d��Y n0 e�e�Z dZ edd� �Z dd� Z G dd� de �Z dS )z SQLAlchemy result store backend.� N)�contextmanager��wraps)�states)� BaseBackend)�ImproperlyConfigured)�maybe_timedelta� )�Task� TaskExtended�TaskSet)�SessionManager)� DatabaseError�InvalidRequestError)�StaleDataErrorzhThe database result backend requires SQLAlchemy to be installed.See https://pypi.org/project/SQLAlchemy/)�DatabaseBackendc c sD z4z d V W n t y( | �� � Y n0 W | �� n | �� 0 d S )N)� Exception�rollback�close)�session� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/backends/database/__init__.py�session_cleanup s r c s t � �� fdd��}|S )Nc sv |� dd�}t|�D ]\}z� | i |��W S tttfyn tjd� j|| d dd� |d |krj� Y q0 qd S )N� max_retries� z-Failed operation %s. Retrying %s more times.r T)�exc_info)�pop�ranger r r �logger�warning�__name__)�args�kwargsr �retries��funr r �_inner) s � zretry.<locals>._innerr )r% r& r r$ r �retry' s r' c s� e Zd ZdZdZeZeZd � fdd� Z e dd� �Z e � fdd �Z ed d d ��Zd d d �Zedd� �Zedd� �Zedd� �Zedd� �Zedd� �Zdd� Zd � fdd � Z� ZS )!r z The database result backend.g �?Nc s� t � jf t|d�|�� | jj}| jr,t| _|p8|p8|j| _ t |pDi fi |j pPi ��| _ |� d|j�| _|jppi }|jpzi }| jj|� d�|� d�d� | jj|� d�|� d�d� | j s�td��d S )N)Z expires_type�url�short_lived_sessions�task)Zschema�name�groupzTMissing connection string! Do you have the database_url setting set to a real value?)�super�__init__r �app�conf�extended_resultr �task_clsZ database_urlr( �dictZdatabase_engine_options�engine_options�getZ database_short_lived_sessionsr) Zdatabase_table_schemasZdatabase_table_names� configure� taskset_clsr )�self�dburir4 r( r" r0 ZschemasZ tablenames�� __class__r r r. E s@ ����� ���zDatabaseBackend.__init__c C s | j j�dd�S )N�extended�result)r/ r0 Zfind_value_for_key)r8 r r r r1 e s z DatabaseBackend.extended_resultc C s |j f | j| jd�| j��S )N)r9 r) )Zsession_factoryr( r) r4 )r8 Zsession_managerr r r � ResultSessioni s ��z DatabaseBackend.ResultSessionc K s� | � � }t|��| t|�| j��| jj|k��}|o:|d }|sb| �|�}||_|�|� |�� | j |||||d� |� � W d � n1 s�0 Y dS )z1Store return value and state of an executed task.r )� traceback�requestN) r> r �list�queryr2 �filter�task_id�add�flush�_update_result�commit) r8 rD r= �stater? r@ r" r r* r r r � _store_resulto s z DatabaseBackend._store_resultc C sN | j ||||ddd�}dd� | jjjD �}|D ]}|�|�} t||| � q.d S )NFT)r= rI r? r@ Z format_date�encodec S s g | ]}|j d vr|j �qS )> rD �id)r+ )�.0�columnr r r � <listcomp>� s �z2DatabaseBackend._update_result.<locals>.<listcomp>)Z_get_result_metar2 Z __table__�columnsr5 �setattr) r8 r* r= rI r? r@ �metarP rN �valuer r r rG � s � z DatabaseBackend._update_resultc C s� | � � }t|��� t|�| j��| jj|k��}|o:|d }|sX| �|�}tj|_ d|_ |� � }|� dd�dur�| � |d �|d< |� dd�dur�| � |d �|d< | �|�W d � S 1 s�0 Y dS )z$Get task meta-data for a task by id.r Nr! r" )r> r rA rB r2 rC rD r ZPENDING�statusr= �to_dictr5 �decodeZmeta_from_decoded)r8 rD r r* �datar r r �_get_task_meta_for� s z"DatabaseBackend._get_task_meta_forc C s^ | � � }t|��: | �||�}|�|� |�� |�� |W d � S 1 sP0 Y dS )z&Store the result of an executed group.N)r> r r7 rE rF rH )r8 �group_idr= r r, r r r � _save_group� s zDatabaseBackend._save_groupc C sl | � � }t|��H |�| j��| jj|k��� }|rJ|�� W d � S W d � n1 s^0 Y dS )z Get meta-data for group by id.N)r> r rB r7 rC � taskset_id�firstrU )r8 rY r r, r r r �_restore_group� s �z DatabaseBackend._restore_groupc C sb | � � }t|��> |�| j��| jj|k��� |�� |�� W d � n1 sT0 Y dS )z!Delete meta-data for group by id.N) r> r rB r7 rC r[ �deleterF rH )r8 rY r r r r � _delete_group� s �z DatabaseBackend._delete_groupc C sZ | � � }t|��6 |�| j��| jj|k��� |�� W d � n1 sL0 Y dS )zForget about result.N)r> r rB r2 rC rD r^ rH )r8 rD r r r r �_forget� s zDatabaseBackend._forgetc C s� | � � }| j}| j�� }t|��\ |�| j��| jj|| k �� � |�| j ��| j j|| k �� � |� � W d � n1 s�0 Y dS )zDelete expired meta-data.N) r> �expiresr/ �nowr rB r2 rC Z date_doner^ r7 rH )r8 r ra rb r r r �cleanup� s � �zDatabaseBackend.cleanupr c s2 |si n|}|� | j| j| jd�� t� �||�S )N)r9 ra r4 )�updater( ra r4 r- � __reduce__)r8 r! r" r: r r re � s ��zDatabaseBackend.__reduce__)NNN)NN)NN)r N)r � __module__� __qualname__�__doc__Zsubpolling_intervalr r2 r r7 r. �propertyr1 r r> r' rJ rG rX rZ r] r_ r` rc re � __classcell__r r r: r r ; s6 � � r )!rh �logging� contextlibr Z vine.utilsr Zceleryr Zcelery.backends.baser Zcelery.exceptionsr Zcelery.utils.timer �modelsr r r r r Zsqlalchemy.excr r Zsqlalchemy.orm.excr � ImportError� getLoggerr r �__all__r r' r r r r r �<module> s, �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка