Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/compat.cpython-39.pyc
Ðазад
a o�h` � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z m Z erTddl m Z d Ze jZdd d �ZG dd� dej�ZG dd� dej�ZG dd� dej�Zd S )zYCarrot compatibility interface. See https://pypi.org/project/carrot/ for documentation. � )� annotations)�count)� TYPE_CHECKING� )� messaging)�Exchange�Queue)� TracebackType)� Publisher�ConsumerFNc c s8 |j |d� td�D ] }|r(||kr( q4| �� V qd S )N)�no_ackr )�consumer Z drain_events)� connection�consumerr �limit� iteration� r �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/compat.py� _iterconsume s r c sv e Zd ZdZdZdZdZdZdZdZ d� fdd� Z d d � Z � fd d �Z d d� Z ddddd�dd�Zedd� �Z� ZS )r zCarrot compatible producer.� �directTFNc s� |r|}|p| j | _ |p | j| _|p(| j| _|d ur:|| _|d urH|| _t| j t�srt| j | j| j| j| jd�| _ t� j|| j fi |�� d S )N)�name�type� routing_key� auto_delete�durable) �exchange� exchange_typer r r � isinstancer �super�__init__) �selfr r r r r r �channel�kwargs�� __class__r r r ) s" �zPublisher.__init__c O s | j |i |��S �N)�publish)r! �argsr# r r r �send@ s zPublisher.sendc s t � �� d| _d S �NT)r �close�_closed�r! r$ r r r+ C s zPublisher.closec C s | S r& r r- r r r � __enter__G s zPublisher.__enter__�type[BaseException] | None�BaseException | None�TracebackType | None�None��exc_type�exc_val�exc_tb�returnc C s | � � d S r& �r+ �r! r4 r5 r6 r r r �__exit__J s zPublisher.__exit__c C s | j S r& )r" r- r r r �backendR s zPublisher.backend)NNNNNN)�__name__� __module__� __qualname__�__doc__r r r r r r, r r) r+ r. r: �propertyr; � __classcell__r r r$ r r s" � r c s� e Zd ZdZdZdZdZdZdZdZ dZ dZ d$� fdd� Z � fd d �Z d d � Zd d� Zddddd�dd�Zdd� Zd%dd�Zdd� Zd&d d �Zd'd d �Zd(d d!�Zd)d"d#�Z� ZS )*r zCarrot compatible consumer.r r TFNc s� |� � | _|d ur|| _|d ur&|| _|d ur4|| _|p<| j| _|pH| j| _|pT| j| _|p`| j| _t | j| j| j| j| jd�}t | j|| j| j| j| jd�}t � j | j|fi | �� d S )N)r r r r )r r r � exclusiver ) r" r; r rB r �queuer r r r r r r ) r! r rC r r r r rB r r# r$ r r r c s2 ��zConsumer.__init__c s || _ t� �|� d S r& �r; r �revive�r! r" r$ r r rE � s zConsumer.revivec C s | � � | j�� d| _d S r* )�cancelr; r+ r, r- r r r r+ � s zConsumer.closec C s | S r& r r- r r r r. � s zConsumer.__enter__r/ r0 r1 r2 r3 c C s | � � d S r& r8 r9 r r r r: � s zConsumer.__exit__c C s | j dd�S )NT)�infinite)� iterqueuer- r r r �__iter__� s zConsumer.__iter__c C s8 |d u r| j }| jd �|�}|r4|r4| �|j|� |S )Nr )r �queues�getZreceive�payload)r! r Zenable_callbacks�messager r r �fetch� s zConsumer.fetchc C s t d��d S )Nz Use fetch(enable_callbacks=True))�NotImplementedErrorr- r r r � process_next� s zConsumer.process_nextc C s |d urt d��| �� S )Nz&discard_all does not implement filters)rP �purge)r! � filterfuncr r r � discard_all� s �zConsumer.discard_allc C s t | j| ||�S r& �r r �r! r r r r r � iterconsume� s zConsumer.iterconsumec C s | � |�}t|�S r& )rW �list)r! r �itr r r �wait� s z Consumer.waitc c s: t � D ].}| �� }|s |d u s*|r.||kr. q6|V qd S r& )r rO )r! r rH Zitems_since_start�itemr r r rI � s ��zConsumer.iterqueue)NNNNNNN)NF)N)NN)N)NF)r< r= r> r? rC r r r r rB r r, r rE r+ r. r: rJ rO rQ rT rW rZ rI rA r r r$ r r W s0 � r c sT e Zd Zd� fdd� Zddd�Zdd� Zd d � Zd d � Z� fd d�Zdd� Z � Z S )� ConsumerSetNc s� |rd| _ || _nd| _ |�� | _g }|r@|D ]}|�|j� q.|rn|�� D ] \}} |�tj|fi | ��� qLt � j | j|fi |�� d S )NTF) �_provided_channelr; r" �extendrK �items�appendr � from_dictr r ) r! r ra Z consumersr" r# rK r Z queue_nameZ queue_optionsr$ r r r � s zConsumerSet.__init__Fc C s t | j| ||�S r& rU rV r r r rW � s zConsumerSet.iterconsumec C s | � � S r& )rR r- r r r rT � s zConsumerSet.discard_allc K s | � tj|fi |���S r& )� add_queuer ra )r! rC �optionsr r r �add_consumer_from_dict� s z"ConsumerSet.add_consumer_from_dictc C s |j D ]}| �|� qd S r& )rK rb )r! r rC r r r � add_consumer� s zConsumerSet.add_consumerc s || _ t� �|� d S r& rD rF r$ r r rE � s zConsumerSet.revivec C s | � � | js| j�� d S r& )rG r] r" r+ r- r r r r+ � s zConsumerSet.close)NNN)NF) r< r= r> r rW rT rd re rE r+ rA r r r$ r r\ � s � r\ )FN)r? � __future__r � itertoolsr �typingr r r �entityr r �typesr �__all__ra Zentry_to_queuer ZProducerr r r\ r r r r �<module> s 8c
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка