Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/loaders/__pycache__/base.cpython-39.pyc
Ðазад
a t�h�# � @ s� d Z ddlZddlZddlZddlZddlmZmZ ddlmZ ddl m Z ddl m Z ddl mZ ddlmZmZ dd lmZ dd lmZmZmZmZ d Zd ad Zed Z e � Z G dd� d�Z ddd�Z dd� Z!dS )zLoader base class.� N)�datetime�timezone)�json)�cached_property)�signals)�reraise)� DictAttribute� force_mapping)� maybe_list)� NotAPackage� find_module�import_from_cwd�symbol_by_name)� BaseLoaderFzPError: Module '{module}' doesn't exist, or it's not a valid Python module name. zDid you mean '{suggest}'? c @ s e Zd ZdZe� ZdZi ZdZe Z dd� Z d7dd�Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� Zd8dd�Zd9dd�Zdd� Zdd � Zd d � Zd d � Zd:d!d"�Zd;d#d$�Zd%d&� Zd'd(� Z d)e � d*�ddfd+d,�Z d<d.d/�Z d=d1d2�Z!e"d3d4� �Z#e$d5d6� �Z%dS )>r a� Base class for loaders. Loaders handles, * Reading celery client/worker configurations. * What happens when a task starts? See :meth:`on_task_init`. * What happens when the worker starts? See :meth:`on_worker_init`. * What happens when the worker shuts down? See :meth:`on_worker_shutdown`. * What modules are imported to find tasks? Fc K s || _ t� | _d S �N)�app�set� task_modules)�selfr �kwargs� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/loaders/base.py�__init__; s zBaseLoader.__init__Tc C s |rt �tj�S t �� S r )r �nowr �utc)r r r r r r ? s zBaseLoader.nowc C s dS )z!Called before a task is executed.Nr )r �task_id�taskr r r � on_task_initD s zBaseLoader.on_task_initc C s dS )z Called after a task is executed.Nr �r r r r �on_process_cleanupG s z BaseLoader.on_process_cleanupc C s dS )z9Called when the worker (:program:`celery worker`) starts.Nr r r r r �on_worker_initJ s zBaseLoader.on_worker_initc C s dS )z=Called when the worker (:program:`celery worker`) shuts down.Nr r r r r �on_worker_shutdownM s z BaseLoader.on_worker_shutdownc C s dS )z#Called when a child process starts.Nr r r r r �on_worker_process_initP s z!BaseLoader.on_worker_process_initc C s | j �|� | �|�S r )r �addr �r �moduler r r �import_task_moduleS s z BaseLoader.import_task_moduleNc C s t j||d�S �N)�package)� importlib� import_module)r r% r( r r r r* W s zBaseLoader.import_modulec C s t ||d u r| jn||d�S r' )r r* )r r% �impr( r r r r Z s �zBaseLoader.import_from_cwdc s@ t jj� jd�}|D ]\}}t|t�r|�q� fdd�� jD �S )N)Zsenderc s g | ]}� � |��qS r )r& )�.0�mr r r � <listcomp>i � z5BaseLoader.import_default_modules.<locals>.<listcomp>)r Zimport_modules�sendr � isinstance� Exception�default_modules)r � responses�_�responser r r �import_default_modulesa s z!BaseLoader.import_default_modulesc C s | j s d| _ | �� | �� d S )NT)�worker_initializedr7 r r r r r � init_workerk s zBaseLoader.init_workerc C s | � � d S r )r! r r r r �shutdown_workerq s zBaseLoader.shutdown_workerc C s | � � d S r )r" r r r r �init_worker_processt s z BaseLoader.init_worker_processc C sl t |t�rBz| j|| jd�}W n" ttfy@ |r:Y dS � Y n0 t|�| _| j�d�d urh| jd | _ dS )N�r+ F�override_backendsT) r1 �str� _smart_importr � ImportError�AttributeErrorr �_conf�getr= )r �objZsilentr r r �config_from_objectw s z BaseLoader.config_from_objectc C sT |d u r| j n|}d|v r&t||d�S z ||�W S tyN t||d� Y S 0 d S )N�:r< )r* r r@ )r �pathr+ r r r r? � s zBaseLoader._smart_importc C s� z| � |� W nj tyx } zR|�d�rRttttj||d d� d��t�� d � ttj|d��|�W Y d }~nd }~0 0 | � |�S d S )Nz.py���)r% Zsuggest� )r% ) r r �endswithr �CONFIG_WITH_SUFFIX�format�sys�exc_info�CONFIG_INVALID_NAMEr )r �name�excr r r �_import_config_module� s � �(z BaseLoader._import_config_modulec C s t |�S r )r r$ r r r r � s zBaseLoader.find_module�celeryz \((\w+)\)c s~ |r|ndt ji}�r�n dddd��ddlm� m} �o@��� �t|jfi |���� ����fdd��t�fdd�|D ��S ) Nr )�tuple�list�dictr )� NAMESPACES�Optionc s | � dd�\}}|�� �dd�}|d dkr@�|dd� }}n|� dd�\}}|r\|d p^d| }��|�}|r�|�� d }��||�}|t|�� �d� }�| |�}nRz� |�� | �|�}W n6 t y� } z t |�d|� ���W Y d}~n d}~0 0 ||fS ) z-Parse single configuration from command-line.�=� �.r5 r N� z: ) �split�lower�replace�match�groupsrC �len�groupZ to_python� ValueError)�arg�key�value�nsZns_key�cast�type_rQ )rW � namespace�override_types�re_type�typemapr r �getarg� s" (z0BaseLoader.cmdline_config_parser.<locals>.getargc 3 s | ]}� |�V qd S r r )r, re )ro r r � <genexpr>� r/ z3BaseLoader.cmdline_config_parser.<locals>.<genexpr>)r �loadsZcelery.app.defaultsrW rX r^ rV rn )r �argsrk rm Z extra_typesrl rX r )rW ro rk rl rm rn r �cmdline_config_parser� s � z BaseLoader.cmdline_config_parser�CELERY_CONFIG_MODULEc C s< zt j| }W n ty Y n0 |r8| �|�}t|�S d S r )�os�environ�KeyErrorrR r )r �envZ custom_configZusercfgr r r �read_configuration� s z BaseLoader.read_configuration�tasksc C s$ | j �dd� t|pd|�D �� d S )Nc s s | ]}|r|j V qd S r )�__name__)r, �modr r r rp � s �z0BaseLoader.autodiscover_tasks.<locals>.<genexpr>r )r �update�autodiscover_tasks)r �packages� related_namer r r r~ � s ��z BaseLoader.autodiscover_tasksc C s. t | j�t t| jjj�� t t| jjj�� S r )rT �builtin_modulesr r �confZimports�includer r r r r3 � s ���zBaseLoader.default_modulesc C s | j tu r| �� | _ | j S )zLoader configuration.)rB � unconfiguredry r r r r r� � s zBaseLoader.conf)T)N)NN)F)N)rt )rz )&r{ � __module__� __qualname__�__doc__� frozensetr� Z configuredr= r8 r� rB r r r r r r! r" r& r* r r7 r9 r: r; rE r? rR r �re�compilers ry r~ r r3 �propertyr� r r r r r ! sF � / r rz c s0 t rdS da z� fdd�| D �W da S da 0 d S )Nr Tc s g | ]}t |� ��qS r )�find_related_module)r, �pkg�r� r r r. � r/ z&autodiscover_tasks.<locals>.<listcomp>F)�_RACE_PROTECTION)r r� r r� r r~ � s �r~ c C s� z t �| �}|s|r|W S W n( tyD | �d�\} }}| s@� Y n0 | � d|� �}z t �|�W S ty� } z6t|dd�}|r�||kr�W Y d}~dS |�W Y d}~n d}~0 0 dS )zFind module in package.r[ rP N)r) r* �ModuleNotFoundError� rpartition�getattr)r( r� r% r5 � module_name�eZimport_exc_namer r r r� � s r� )rz )"r� r) ru r� rM r r Z kombu.utilsr Zkombu.utils.objectsr rS r Zcelery.exceptionsr Zcelery.utils.collectionsr r Zcelery.utils.functionalr Zcelery.utils.importsr r r r �__all__r� rO rK �objectr� r r~ r� r r r r �<module> s* O
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0.01 |
proxy
|
phpinfo
|
ÐаÑтройка