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/concurrency/__pycache__/ |
a
��Sh� � @ s� d Z ddlZddlmZ ddlmZmZ ddlmZm Z ddlm
Z ddl m
Z
mZ ddlmZmZ dd lmZ dd
lmZ dd lmZ dd lmZ d
dlmZ dZ h d�Z er�dehZ ndhZ ee �Z e j!e j" Z!Z"dd� Z#dd� Z$G dd� de�Z%dS )zKPrefork execution pool.
Pool implementation using :mod:`multiprocessing`.
� N)�forking_enable)�
REMAP_SIGTERM� TERM_SIGNAME)�CLOSE�RUN)�Pool)� platforms�signals)�_set_task_join_will_block�set_default_app)�trace)�BasePool)�noop)�
get_logger� )�AsynPool)�TaskPool�process_initializer�process_destructor> �SIGTERM�SIGTTOU�SIGHUP�SIGUSR1�SIGTTIN�SIGINTc C sN t �d� td� t jjt� t jjt� t jd|d� | j �
� | j � � t j
�d�pZd}|rtd|�� v rtd| j_| jjtt j
�d d
�p�d
�|tt j
�d d��tt j
�d ��|d� t j
�d
�r�t�| |� n | �� t| � | �� | jt_d
dl m } | j � � D ] \}}|||| j || d�|_ �qd
dl!m"} |�#� tj$j%dd� dS )z�Pool child process initializer.
Initialize the child pool process to ensure the correct
app instance is used and things like logging works.
�SIGKILLTZceleryd)�hostnameZCELERY_LOG_FILENz%iFZCELERY_LOG_LEVELr ZCELERY_LOG_REDIRECTZCELERY_LOG_REDIRECT_LEVELZFORKED_BY_MULTIPROCESSING)� build_tracer)�app)�state)�sender)&r Z
set_pdeathsigr
r �reset�WORKER_SIGRESET�ignore�WORKER_SIGIGNOREZset_mp_process_title�loaderZ init_workerZinit_worker_process�os�environ�get�lower�logZ
already_setup�setup�int�bool�strr Zsetup_worker_optimizationsZ set_currentr �finalizeZ_tasksZcelery.app.tracer �tasks�itemsZ __trace__Z
celery.workerr Z reset_stateZworker_process_init�send)r r �logfiler �name�taskZ worker_state� r6 �D/usr/local/lib/python3.9/site-packages/celery/concurrency/prefork.pyr & s<
� � r c C s t jjd| |d� dS )z_Pool child process destructor.
Dispatch the :signal:`worker_process_shutdown` signal.
N)r �pid�exitcode)r Zworker_process_shutdownr2 )r8 r9 r6 r6 r7 r R s �r c st e Zd ZdZeZeZdZdZdd� Z dd� Z
dd � Z d
d � Z d d
� Z
dd� Zdd� Z� fdd�Zedd� �Z� ZS )r z$Multiprocessing Pool implementation.TNc C s� t | j � | j�dd�r | jn| j}| jr4| jjjnd }|f | jt t
dd|d�| j�� }| _ |j | _
|j| _|j| _|j| _|j| _t|dd �| _d S )N�threadsTF)� processesZ initializerZon_process_exitZenable_timeoutsZsynack�proc_alive_timeout�flush)r �optionsr( � BlockingPoolr r �confZworker_proc_alive_timeout�limitr r �_pool� apply_asyncZon_applyZ
maintain_poolZ
terminate_jobZgrow�shrink�getattrr= )�selfr r< �Pr6 r6 r7 �on_starte s,
���� zTaskPool.on_startc C s | j �� | j �t� d S �N)rB �restartrC r �rF r6 r6 r7 rJ } s
zTaskPool.restartc C s
| j �� S rI )rB � did_start_okrK r6 r6 r7 rL � s zTaskPool.did_start_okc C s* z | j j}W n ty Y d S 0 ||�S rI )rB �register_with_event_loop�AttributeError)rF �loop�regr6 r6 r7 rM � s
z!TaskPool.register_with_event_loopc C s8 | j dur4| j jttfv r4| j �� | j �� d| _ dS )zGracefully stop the pool.N)rB �_stater r �close�joinrK r6 r6 r7 �on_stop� s
zTaskPool.on_stopc C s | j dur| j �� d| _ dS )zForce terminate the pool.N)rB � terminaterK r6 r6 r7 � on_terminate� s
zTaskPool.on_terminatec C s$ | j d ur | j jtkr | j �� d S rI )rB rQ r rR rK r6 r6 r7 �on_close� s zTaskPool.on_closec sp t | jdd �}t� �� }|�| jdd� | jjD �| jjp:d| j| jjpHd| jj pRdf|d urb|� ndd�� |S )NZhuman_write_statsc S s g | ]
}|j �qS r6 )r8 )�.0�pr6 r6 r7 �
<listcomp>� � z&TaskPool._get_info.<locals>.<listcomp>zN/Ar )zmax-concurrencyr; zmax-tasks-per-childzput-guarded-by-semaphoreZtimeoutsZwrites)
rE rB �super� _get_info�updaterA Z_maxtasksperchildZputlocksZ soft_timeout�timeout)rF � write_stats�info�� __class__r6 r7 r] � s
�� zTaskPool._get_infoc C s | j jS rI )rB Z
_processesrK r6 r6 r7 �
num_processes� s zTaskPool.num_processes)�__name__�
__module__� __qualname__�__doc__r r r? Zuses_semaphorer` rH rJ rL rM rT rV rW r] �propertyrd �
__classcell__r6 r6 rb r7 r \ s r )&rh r& Zbilliardr Zbilliard.commonr r Z
billiard.poolr r r r? Zceleryr r Z
celery._stater
r Z
celery.appr Zcelery.concurrency.baser
Zcelery.utils.functionalr Zcelery.utils.logr Zasynpoolr �__all__r" r$ re �logger�warning�debugr r r r6 r6 r6 r7 �<module> s,
,