Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/app/__pycache__/routes.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZmZ dd lmZ z ejZW n ey� ejZY n0 d ZG d d � d �ZG d d� d�Zdd� Zdd� ZdS )z[Task Routing. Contains utilities for working with task routers, (:setting:`task_routes`). � N)� OrderedDict)�Mapping)�Queue)� QueueNotFound)�lpmerge)�maybe_evaluate�mlazy)�symbol_by_name)�MapRoute�Router�preparec @ s e Zd ZdZdd� Zdd� ZdS )r z(Creates a router out of a :class:`dict`.c C sv t |t�r|�� n|}i | _t� | _|D ]H\}}t |t�rF|| j|< q(d|v rf|| jt�t � |��< q(|| j|< q(d S )N�*) � isinstancer �items�mapr �patterns�Pattern�re�compile�fnmatch� translate)�selfr �k�v� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/app/routes.py�__init__ s zMapRoute.__init__c O s� zt | j| �W S ty" Y n ty@ d| j| i Y S 0 | j�� D ]@\}}|�|�rLzt |�W S ty� d|i Y S 0 qLd S �N�queue)�dictr �KeyError� ValueErrorr r �match)r �name�args�kwargs�regex�router r r �__call__) s zMapRoute.__call__N)�__name__� __module__� __qualname__�__doc__r r( r r r r r s r c @ s> e Zd ZdZddd�Zddd�Zd d � Zdd d �Zd d� ZdS )r z8Route tasks based on the :setting:`task_routes` setting.NFc C s4 || _ |d u ri n|| _|d u r$g n|| _|| _d S �N)�app�queues�routes�create_missing)r r0 r/ r1 r. r r r r ; s zRouter.__init__r c C sd |si n|}| � |�}| jrB| �|||||�}|rBt| � |�|�S d|vr`t| � | jjj�|�}|S r )�expand_destinationr0 � lookup_router r. ZconfZtask_default_queue)r �optionsr# r$ r% � task_typer' r r r r' B s ��z Router.routec C st t |t�r|i }}n |�dd �}|rpt |t�r:||d< n6z| j| |d< W n" tyn td|�d���Y n0 |S )Nr zQueue z missing from task_queues)r �str�popr r/ r r )r r' r r r r r2 N s � zRouter.expand_destinationc C s8 | j }| jD ]&}|||||||�}|d ur | S q d S r- )� query_routerr0 ) r r# r$ r% r4 r5 �query�routerr' r r r r3 b s zRouter.lookup_routec C s2 t |�}t|d�r |�|||�S ||||||d�S )N�route_for_task)�task)r �hasattrr; )r r: r< r$ r% r4 r5 r r r r8 j s zRouter.query_router)NNFN)r NN)NNNN) r) r* r+ r, r r' r2 r3 r8 r r r r r 8 s � � r c C s t | �} t| d�r| � } | S )Nr; )r r= )r: r r r �expand_router_stringr s r> c s: dd� � | du rdS t | ttf�s(| f} � fdd�| D �S )z*Expand the :setting:`task_routes` setting.c S s0 t | tttf�rt| �S t | t�r,tt| �S | S r- )r r �list�tupler r6 r r> )r' r r r � expand_route} s z prepare.<locals>.expand_routeNr c s g | ] }� |��qS r r )�.0r' �rA r r � <listcomp>� � zprepare.<locals>.<listcomp>)r r? r@ )r0 r rC r r z s r )r, r r � collectionsr �collections.abcr Zkombur Zcelery.exceptionsr Zcelery.utils.collectionsr Zcelery.utils.functionalr r Zcelery.utils.importsr Z _pattern_typer �AttributeError�__all__r r r> r r r r r �<module> s$ :
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка