File: //usr/local/lib/python3.9/site-packages/celery/__pycache__/local.cpython-39.pyc
a
X>h�> � @ s2 d Z ddlZddlZddlmZ ddlmZ ddlmZ dZ e
Z dd� Z d1d d
�Z
G d d � d �ZG d
d� de�Zdd� ZdZh d�Zdd� Zdd� Zdddidddd �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 d/d0� Z dS )2z�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_� �6/usr/local/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.
> �__path__�__all__�__file__r" 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_logging_subsystemz log.redirect_stdouts_to_logger)Zget_default_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> sX
gG ������ �
�