Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/__pycache__/local.cpython-39.pyc
Ðазад
a t�h�> � @ s4 d Z ddlZddlZddlmZ ddlmZ ddlmZ dZ e Z dd� Z d2d d �Z G d d � d �ZG d d� de�Zdd� ZdZh d�Zdd� Zdd� Zdddidddd d �d d d d �d!d!id"�iZeed �� �d#hB ZG d$d%� d%�Zd&d'� ZG d(d)� d)e�Zddedfd*d+�Z dddefd,d-�Z d.d/� Z d0d1� Z dS )3z�Proxy/PromiseProxy implementation. This module contains critical utilities that needs to be loaded as soon as possible, and that shall not load any third party modules. Parts of this module is Copyright by Werkzeug Team. � N)�reduce)� import_module)� ModuleType)�Proxy� PromiseProxy� try_import�maybe_evaluatec s, � �fdd�}ddd�}t | �f||d��S )Nc s �� | � �}||_|S �N)�__new__�__getter)�cls�getter�instance�� cls_value�type_� �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/local.pyr s z"_default_cls_attr.<locals>.__new__c S s |d ur| � |�S | S r )r )�self�objr r r r �__get__ s z"_default_cls_attr.<locals>.__get__)r r )N)�type)�namer r r r r r r �_default_cls_attr s �r c C s& z t | �W S ty | Y S 0 dS )zUTry to import and return module. Returns None if the module does not exist. N)r � ImportError)�module�defaultr r r r ( s r c @ s" e Zd ZdZdZd|dd�Zedee �dd� �Z ed ee �d d � �Zed ee�d d� �Zedee�dd� �Zdd� Ze dd� �Z dd� Z e dd� �Z dd� Z d d � ZeZd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Zd6d7� Z d8d9� Z d:d;� Z d<d=� Z d>d?� Z d@dA� Z!dBdC� Z"dDdE� Z#dFdG� Z$dHdI� Z%dJdK� Z&dLdM� Z'dNdO� Z(dPdQ� Z)dRdS� Z*dTdU� Z+dVdW� Z,dXdY� Z-dZd[� Z.d\d]� Z/d^d_� Z0d`da� Z1dbdc� Z2ddde� Z3dfdg� Z4dhdi� Z5djdk� Z6dldm� Z7dndo� Z8dpdq� Z9drds� Z:dtdu� Z;dvdw� Z<dxdy� Z=dzd{� Z>dS )}r zProxy to another object.)Z__localZ__argsZ__kwargs�__dict__Nc C sb t �| d|� t �| d|p d� t �| d|p.i � |d urHt �| d|� |d ur^t �| d|� d S )N� _Proxy__local� _Proxy__argsr �_Proxy__kwargs�__custom_name__�__doc__)�object� __setattr__)r �local�args�kwargsr r" r r r �__init__9 s zProxy.__init__r c C s* z| j W S ty$ | �� j Y S 0 d S r )r! �AttributeError�_get_current_object�__name__�r r r r r+ C s zProxy.__name__�qualnamec C s* z| j W S ty$ | �� j Y S 0 d S r )r! r) r* � __qualname__r, r r r r. J s zProxy.__qualname__r c C s | � � jS r )r* � __module__r, r r r r/ Q s zProxy.__module__�docc C s | � � jS r )r* r" r, r r r r" U s z Proxy.__doc__c C s | � � jS r )r* � __class__r, r r r � _get_classY s zProxy._get_classc C s | � � S r )r2 r, r r r r1 \ s zProxy.__class__c C s^ t �| d�}t|d�s(|| ji | j��S zt|| j�W S tyX td| j� ���Y n0 dS )z�Get current object. This is useful if you want the real object behind the proxy at a time for performance reasons or because you want to pass the object into a different context. r Z__release_local__zno object bound to N) r# �__getattribute__�hasattrr r �getattrr+ r) � RuntimeError)r �locr r r r* ` s zProxy._get_current_objectc C s, z | � � jW S ty& td��Y n0 d S )Nr )r* r r6 r) r, r r r r p s zProxy.__dict__c C s8 z | � � }W n" ty. d| jj� d� Y S 0 t|�S )N�<z unbound>)r* r6 r1 r+ �repr)r r r r r �__repr__w s zProxy.__repr__c C s( zt | �� �W S ty" Y dS 0 d S )NF)�boolr* r6 r, r r r �__bool__~ s zProxy.__bool__c C s* zt | �� �W S ty$ g Y S 0 d S r )�dirr* r6 r, r r r �__dir__� s z Proxy.__dir__c C s" |dkrt | �� �S t| �� |�S )N� __members__)r= r* r5 �r r r r r � __getattr__� s zProxy.__getattr__c C s || � � |< d S r �r* )r �key�valuer r r � __setitem__� s zProxy.__setitem__c C s | � � |= d S r rB )r rC r r r � __delitem__� s zProxy.__delitem__c C s t | �� ||� d S r )�setattrr* )r r rD r r r r$ � s zProxy.__setattr__c C s t | �� |� d S r )�delattrr* r@ r r r � __delattr__� s zProxy.__delattr__c C s t | �� �S r )�strr* r, r r r �__str__� s z Proxy.__str__c C s | � � |k S r rB �r �otherr r r �__lt__� s z Proxy.__lt__c C s | � � |kS r rB rL r r r �__le__� s z Proxy.__le__c C s | � � |kS r rB rL r r r �__eq__� s z Proxy.__eq__c C s | � � |kS r rB rL r r r �__ne__� s z Proxy.__ne__c C s | � � |kS r rB rL r r r �__gt__� s z Proxy.__gt__c C s | � � |kS r rB rL r r r �__ge__� s z Proxy.__ge__c C s t | �� �S r )�hashr* r, r r r �__hash__� s zProxy.__hash__c O s | � � |i |��S r rB �r �a�kwr r r �__call__� s zProxy.__call__c C s t | �� �S r )�lenr* r, r r r �__len__� s z Proxy.__len__c C s | � � | S r rB �r �ir r r � __getitem__� s zProxy.__getitem__c C s t | �� �S r )�iterr* r, r r r �__iter__� s zProxy.__iter__c C s || � � v S r rB r\ r r r � __contains__� s zProxy.__contains__c C s | � � | S r rB rL r r r �__add__� s z Proxy.__add__c C s | � � | S r rB rL r r r �__sub__� s z Proxy.__sub__c C s | � � | S r rB rL r r r �__mul__� s z Proxy.__mul__c C s | � � | S r rB rL r r r � __floordiv__� s zProxy.__floordiv__c C s | � � | S r rB rL r r r �__mod__� s z Proxy.__mod__c C s | � � �|�S r )r* � __divmod__rL r r r rg � s zProxy.__divmod__c C s | � � | S r rB rL r r r �__pow__� s z Proxy.__pow__c C s | � � |> S r rB rL r r r � __lshift__� s zProxy.__lshift__c C s | � � |? S r rB rL r r r � __rshift__� s zProxy.__rshift__c C s | � � |@ S r rB rL r r r �__and__� s z Proxy.__and__c C s | � � |A S r rB rL r r r �__xor__� s z Proxy.__xor__c C s | � � |B S r rB rL r r r �__or__� s z Proxy.__or__c C s | � � �|�S r )r* �__div__rL r r r rn � s z Proxy.__div__c C s | � � �|�S r )r* � __truediv__rL r r r ro � s zProxy.__truediv__c C s | � � S r rB r, r r r �__neg__� s z Proxy.__neg__c C s | � � S r rB r, r r r �__pos__� s z Proxy.__pos__c C s t | �� �S r )�absr* r, r r r �__abs__� s z Proxy.__abs__c C s | � � S r rB r, r r r � __invert__� s zProxy.__invert__c C s t | �� �S r )�complexr* r, r r r � __complex__� s zProxy.__complex__c C s t | �� �S r )�intr* r, r r r �__int__� s z Proxy.__int__c C s t | �� �S r )�floatr* r, r r r � __float__ s zProxy.__float__c C s t | �� �S r )�octr* r, r r r �__oct__ s z Proxy.__oct__c C s t | �� �S r )�hexr* r, r r r �__hex__ s z Proxy.__hex__c C s | � � �� S r )r* � __index__r, r r r r s zProxy.__index__c C s | � � �|�S r )r* � __coerce__rL r r r r� s zProxy.__coerce__c C s | � � �� S r )r* � __enter__r, r r r r� s zProxy.__enter__c O s | � � j|i |��S r )r* �__exit__rV r r r r� s zProxy.__exit__c C s | � � �� S r )r* � __reduce__r, r r r r� s zProxy.__reduce__)NNNN)?r+ r/ r. r" � __slots__r( r rJ r2 �propertyr1 r* r r: r< � __nonzero__r> rA rE rF r$ rI rK rN rO rP rQ rR rS rU rY r[ r^ r` ra rb rc rd re rf rg rh ri rj rk rl rm rn ro rp rq rs rt rv rx rz r| r~ r r� r� r� r� r r r r r 3 s� � r c @ s> e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zdd d �Z dS )r z�Proxy that evaluates object once. :class:`Proxy` will evaluate the object each time, while the promise will only evaluate it once. )� __pending__� __weakref__c C s. zt �| d�W S ty( | �� Y S 0 d S )N�__thing)r# r3 r) � __evaluate__r, r r r r* " s z PromiseProxy._get_current_objectc O sz | � � r||i |��S ddlm} zt�| d�}W n tyH d }Y n0 |d u rf|� }t�| d|� |�|||f� d S )Nr )�dequer� )� __evaluated__� collectionsr� r# r3 r) r$ �append)r �funr& r' r� �pendingr r r �__then__( s zPromiseProxy.__then__c C s* zt �| d� W n ty$ Y dS 0 dS )Nr� FT)r# r3 r) r, r r r r� 5 s zPromiseProxy.__evaluated__c C s | � � S r rB r, r r r �__maybe_evaluate__< s z PromiseProxy.__maybe_evaluate__�r r r c C s� zt �| �}W n ty" � Y n�0 t�| d|� |D ](}zt�| |� W q6 ty\ Y q60 q6zt�| d�}W n ty� Y nt0 zJ|r�|�� \}}}||i |�� q�W zt�| d� W q� ty� Y q�0 n&zt�| d� W n ty� Y n0 0 |S d S )Nr� r� ) r r* � Exceptionr# r$ rI r) r3 �popleft)r Z_clean�thing�attrr� r� r& r' r r r r� ? s6 � zPromiseProxy.__evaluate__N)r� ) r+ r/ r. r" r� r* r� r� r� r� r r r r r s �r c C s& z | � � W S ty | Y S 0 dS )z:Attempt to evaluate promise, even if obj is not a promise.N)r� r) )r r r r r ` s r zF The module %s is deprecated and will be removed in a future version. > �__file__r" �__all__�__path__c C s | S r r ��methodr r r � fun_of_method{ s r� c C s ddl m} |�| �S )ziGet attribute from current_app recursively. Example: ``getappattr('amqp.get_task_consumer')``. r )� current_app)�celeryr� Z _rgetattr)�pathr� r r r � getappattr s r� r� Z send_taskzlog.get_default_loggerzlog.setup_loggerzlog.setup_logging_subsystemz log.redirect_stdouts_to_logger)Zget_default_loggerZ setup_loggerZsetup_logging_subsystemZredirect_stdouts_to_loggerzamqp.TaskConsumer� connection)Z TaskConsumerZestablish_connectionZget_consumer_set�tasks)�execute�logZ messaging�registryZsubtaskc @ s0 e Zd Zd dd�Zd dd�Zdd� Zdd � ZdS ) �class_propertyNc C sf |d urt |t�st|�}|d ur4t |t�s4t|�}|| _|| _|�t�}|j| _|j| _|j| _d S r ) � isinstance� classmethod�_class_property__get�_class_property__setr r# r" r+ r/ )r r �setter�infor r r r( � s zclass_property.__init__c C s" |r|d u r|j }| j�||�� S r )r1 r� r )r r r r r r r � s zclass_property.__get__c C s |d u r | S | j �|�|�S r )r� r )r r rD r r r �__set__� s zclass_property.__set__c C s | � | j|�S r )r1 r� )r r� r r r r� � s zclass_property.setter)NN)N)r+ r/ r. r( r r� r� r r r r r� � s r� c C s t t| ��S r )r� r� r� r r r � reclassmethod� s r� c @ s4 e Zd ZdZi Zi Zi Zdd� Zdd� Zdd� Z dS ) � LazyModuler c C s� || j v rNt| j | d d |g�}| j|j D ]}t| |t||�� q,t||�S || jv r~t| j| d d |g�}t| ||� |S t�| |�S r ) �_object_origins� __import__�_all_by_moduler+ rG r5 �_directr r3 )r r r �itemr r r rA � s � zLazyModule.__getattr__c C s dd� t | j�tB D �S )Nc S s g | ]}|t vr|�qS r )�DEPRECATED_ATTRS��.0r� r r r � <listcomp>� s �z&LazyModule.__dir__.<locals>.<listcomp>)�setr� � DEFAULT_ATTRSr, r r r r> � s �zLazyModule.__dir__c C s t | jffS r )r r+ r, r r r r� � s zLazyModule.__reduce__N) r+ r/ r. �_compat_modulesr� r� r� rA r> r� r r r r r� � s r� c s� |rd� |j| g�n| }|d u r$i n|}| �d�\}}}||d< � fdd�|�� D �}t||f|�| � } tj|< | j�|� | S )N�.r/ c s" i | ]\}}|� r� |�n|�qS r r )r� � attr_namer� �� prepare_attrr r � <dictcomp>� s �z!create_module.<locals>.<dictcomp>) �joinr+ � rpartition�itemsr �sys�modulesr �update) r �attrs� cls_attrs�pkg�baser� �fqdn�_�modnamer r r� r � create_module� s ��� r� c s� |pt �| d�}|pi }|p i }tj| }t|�}ttttj dd� ||||fD ����}|||||d�} t | || |d�� � j � � fdd�|D �� |j � _ |� fS )Nr c S s g | ] }t |��qS r )�tuple)r� �vr r r r� � � z#recreate_module.<locals>.<listcomp>)r� r� r� r� r� )r� r� c s i | ]}|t � |��qS r )�get_compat_module)r� �mod�Z new_moduler r r� s z#recreate_module.<locals>.<dictcomp>)�COMPAT_MODULES�getr� r� � get_originsr� r� r �operator�addr� r r� �__spec__) r Zcompat_modulesZ by_module�directr� r� Z old_module�originsZ_allZcattrsr r� r �recreate_module� s( ���r� c C sf dd� }t | j | }t|t�rFd�| j|g�}t|� }tj|< |S t|�|d< t |t |�| |d�S )Nc S s t | t�rtt| f�S | S r )r� rJ r r� )r� r r r �prepare s z"get_compat_module.<locals>.preparer� r� )r� r� ) r� r+ r� rJ r� r r� r� �listr� �dict)r� r r� r� r� r r r r r� s r� c s2 i }| � � D ] \� }|�� fdd�|D �� q |S )Nc s i | ] }|� �qS r r r� �r r r r� r� z get_origins.<locals>.<dictcomp>)r� r� )Zdefsr� r� r r� r r� s r� )N) r" r� r� � functoolsr � importlibr �typesr r� r+ r/ r r r r r ZMODULE_DEPRECATEDr� r� r� r� r� �keysr� r� r� r� r� r� r� r� r r r r �<module> sZ gG ������ � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка