Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/abstract.cpython-39.pyc
Ðазад
a o�hJ � @ s� d Z ddlmZ ddlmZ ddlmZmZmZmZ ddl m Z ddl m Z ddl mZ ertdd lmZ dd lmZ d Zed �Zed dd�Zeddd�Zddd d�dd�Zd d d�dd�ZG dd� d�ZG dd� de�Zd S ) zObject utilities.� )� annotations)�copy)� TYPE_CHECKING�Any�Callable�TypeVar� )� maybe_channel)� NotBoundError)�ChannelPromise)� Connection)�Channel)�Object�MaybeChannelBound�_T� _ObjectTyper )�bound�_MaybeChannelBoundTyper ztype[_ObjectType]�dict[str, Any])�cls�kwargs�returnc C s | f i |��S �N� )r r r r �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/abstract.py� unpickle_dict s r )�vr c C s | S r r )r r r r �_any s r c @ sb e Zd ZU dZdZded< dddd�dd �Zdd d d �dd�Zddd�dd�Zddd�dd�Z dS )r zYCommon base class. Supports automatic kwargs->attributes handling, and cloning. r ztuple[tuple[str, Any], ...]�attrsr �None)�argsr r c O sj | j D ]^\}}|�|�}|d ur6t| ||p,t|�� qzt| |� W q tyb t| |d � Y q0 qd S r )r �get�setattrr �getattr�AttributeError)�selfr r �name�type_�valuer r r �__init__, s zObject.__init__F�boolr )�recurser c s. ddddd��fdd� � � �fdd��j D �S ) Nr zCallable[[Any], Any] | None)�obj�typer c s2 � rt | t�r| jdd�S |r.| d ur.|| �S | S )NT�r+ )� isinstancer �as_dict)r, r- r. r r �f8 s zObject.as_dict.<locals>.fc s" i | ]\}}|� t �|�|��qS r )r# )�.0�attrr- )r1 r% r r � <dictcomp>< s z"Object.as_dict.<locals>.<dictcomp>)N)r )r% r+ r )r1 r+ r% r r0 7 s �zObject.as_dictr zktuple[Callable[[type[_ObjectType], dict[str, Any]], _ObjectType], tuple[type[_ObjectType], dict[str, Any]]])r% r c C s t | j| �� ffS r )r � __class__r0 �r% r r r � __reduce__@ s zObject.__reduce__c C s | j f i | �� ��S r )r5 r0 r6 r r r �__copy__F s zObject.__copy__N)F) �__name__� __module__� __qualname__�__doc__r �__annotations__r) r0 r7 r8 r r r r r $ s c @ s� e Zd ZU dZdZded< dZdZdddd�d d �Zdddd�d d �Z dddd�d d�Z ddd�dd�Z dd�dd�Z dd�dd�Z d#ddd�d d �Zed d�d d ��Zedd�d!d"��ZdS )$r z7Mixin for classes that can be bound to an AMQP channel.NzChannel | None�_channelFr zChannel | Connection)r% �channelr c C s | � |�S )z&`self(channel) -> self.bind(channel)`.)�bind�r% r? r r r �__call__S s zMaybeChannelBound.__call__c C s t | ��|�S )z7Create copy of the instance that is bound to a channel.)r � maybe_bindrA r r r r@ Y s zMaybeChannelBound.bindc C s& | j s"|r"t|�| _| �� d| _| S )z.Bind instance to channel if not already bound.T)�is_boundr r> � when_bound� _is_boundrA r r r rC _ s z MaybeChannelBound.maybe_bindr r )r? r c C s | j r|| _| �� dS )zyRevive channel after the connection has been re-established. Used by :meth:`~kombu.Connection.ensure`. N)rD r> rE rA r r r �revivei s zMaybeChannelBound.revive)r c C s dS )z(Callback called when the class is bound.Nr r6 r r r rE s s z MaybeChannelBound.when_bound�strc C s | � t| �j�S r )� _repr_entityr- r9 r6 r r r �__repr__v s zMaybeChannelBound.__repr__� )�itemr c C s: |p t | �j}| jr.d�|p$t | �j| jj�S d|� d�S )Nz<{} bound to chan:{}>z <unbound �>)r- r9 rD �formatr? Z channel_id)r% rL r r r rI y s �z MaybeChannelBound._repr_entityr* c C s | j o| jduS )z!Flag set if the channel is bound.N)rF r> r6 r r r rD � s zMaybeChannelBound.is_boundc C s< | j }|du r"td�t| �j���t|t�r8|� }| _ |S )z'Current channel if the object is bound.Nz.Can't call method on {} not bound to a channel)r> r rN r- r9 r/ r rA r r r r? � s �� zMaybeChannelBound.channel)rK )r9 r: r; r< r> r= rF Zcan_cache_declarationrB r@ rC rG rE rJ rI �propertyrD r? r r r r r J s N)r< � __future__r r �typingr r r r � connectionr � exceptionsr Zutils.functionalr Zkombu.connectionr Zkombu.transport.virtualr �__all__r r r r r r r r r r r �<module> s& �&
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка