Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/loaders/__pycache__/ |
a
��Sh�# � @ 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 �=/usr/local/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 Ztask_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_initializedr6 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)
r0 �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.�=� �.r4 r N� z: )
�split�lower�replace�match�groupsrB �len�groupZ to_python�
ValueError)�arg�key�value�nsZns_key�cast�type_rP )rV � namespace�override_types�re_type�typemapr r �getarg� s"
(z0BaseLoader.cmdline_config_parser.<locals>.getargc 3 s | ]}� |�V qd S r r )r+ rd )rn r r � <genexpr>� r. z3BaseLoader.cmdline_config_parser.<locals>.<genexpr>)r �loadsZcelery.app.defaultsrV rW r] rU rm )r �argsrj rl Z extra_typesrk rW r )rV rn rj rk rl rm 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�KeyErrorrQ 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 ro � 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 )rS �builtin_modulesr
r �confZimports�includer r r r r2 � s ���zBaseLoader.default_modulesc C s | j tu r| �� | _ | j S )zLoader configuration.)rA � unconfiguredrx r r r r r� � s
zBaseLoader.conf)T)N)NN)F)N)rs )ry )&rz �
__module__� __qualname__�__doc__� frozensetr� Z
configuredr< r7 r� rA r r r r r r r! r% r) r
r6 r8 r9 r: rD r> rQ r �re�compilerr rx r} r r2 �propertyr� r r r r r ! sF
�
/
r ry 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.rZ rO N)r( r) �ModuleNotFoundError�
rpartition�getattr)r' r r$ r4 � module_name�eZimport_exc_namer r r r� � s
r� )ry )"r� r( rt r� rL r r Z kombu.utilsr Zkombu.utils.objectsr rR r Zcelery.exceptionsr Zcelery.utils.collectionsr r Zcelery.utils.functionalr
Zcelery.utils.importsr r r
r �__all__r� rN rJ �objectr� r r} r� r r r r �<module> s* O