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
��Shb � @ s� d Z ddlZddlZddlZddlZddlmZmZ ddlm Z ddl
m Z ddl m
Z
ddlmZmZmZ ddlmZ dd lmZ dd
lmZ d Zed �Zd
ddddejd
ejfdd�Z G dd� d�Z dS )zBase Execution Pool.� N)�Any�Dict)�
ExceptionInfo)�WorkerLostError)� safe_repr)�WorkerShutdown�WorkerTerminate�reraise)�timer2)�
get_logger)�truncate)�BasePool� apply_targetz celery.pool� c K s� |si n|}|r"||p|� |� � z| |i |��}
W n� |yH � Y n� t yZ � Y n� ttfyp � Y nj ty� } zJz tttt| ��t�� d � W n ty� |t � � Y n0 W Y d} ~ nd} ~ 0 0 ||
� dS )z#Apply function within pool context.� N)
� Exceptionr r �
BaseExceptionr r �repr�sys�exc_infor ) �target�args�kwargs�callbackZaccept_callback�pid�getpid� propagate� monotonic�_�ret�excr r �A/usr/local/lib/python3.9/site-packages/celery/concurrency/base.pyr s&
� &r c @ s e Zd ZdZdZdZdZejZdZ dZ
dZ dZ dZ
dZdZdZd8d d
�Zd d � Zd
d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd9d d �Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z d)d*� Z!d+d,� Z"d:d-d.�Z#e$e%e&f d/�d0d1�Z'e(d2d3� �Z)e(d4d5� �Z*e(d6d7� �Z+dS );r
z
Task pool.� r � TFNr c K s( || _ || _|| _|| _|| _|| _d S �N)�limit�putlocks�options�forking_enable�callbacks_propagate�app)�selfr% r& r( r) r* r' r r r! �__init__I s zBasePool.__init__c C s d S r$ r �r+ r r r! �on_startR s zBasePool.on_startc C s dS )NTr r- r r r! � did_start_okU s zBasePool.did_start_okc C s d S r$ r r- r r r! �flushX s zBasePool.flushc C s d S r$ r r- r r r! �on_stop[ s zBasePool.on_stopc C s d S r$ r )r+ �loopr r r! �register_with_event_loop^ s z!BasePool.register_with_event_loopc O s d S r$ r �r+ r r r r r! �on_applya s zBasePool.on_applyc C s d S r$ r r- r r r! � on_terminated s zBasePool.on_terminatec C s d S r$ r �r+ Zjobr r r! �on_soft_timeoutg s zBasePool.on_soft_timeoutc C s d S r$ r r7 r r r! �on_hard_timeoutj s zBasePool.on_hard_timeoutc O s d S r$ r r4 r r r! �
maintain_poolm s zBasePool.maintain_poolc C s t t| �� d���d S )Nz does not implement kill_job��NotImplementedError�type)r+ r �signalr r r! �
terminate_jobp s �zBasePool.terminate_jobc C s t t| �� d���d S )Nz does not implement restartr; r- r r r! �restartt s �zBasePool.restartc C s | � � | j| _d S r$ )r1 � TERMINATE�_stater- r r r! �stopx s z
BasePool.stopc C s | j | _| �� d S r$ )rA rB r6 r- r r r! � terminate| s zBasePool.terminatec C s" t �tj�| _| �� | j| _d S r$ )�logger� isEnabledFor�logging�DEBUG� _does_debugr. �RUNrB r- r r r! �start� s zBasePool.startc C s | j | _| �� d S r$ )�CLOSErB �on_closer- r r r! �close� s zBasePool.closec C s d S r$ r r- r r r! rM � s zBasePool.on_closec K sb |si n|}|sg n|}| j rBt�d|tt|�d�tt|�d�� | j|||f| j| jd�|��S )z�Equivalent of the :func:`apply` built-in function.
Callbacks should optimally return as soon as possible since
otherwise the thread which handles the result will get blocked.
z&TaskPool: Apply %s (args:%s kwargs:%s)i )Z waitforslotr) )rI rE �debugr r r5 r& r) )r+ r r r r' r r r! � apply_async� s � ��zBasePool.apply_async)�returnc C s | j jd | j j | jd�S )z�
Return configuration and statistics information. Subclasses should
augment the data as required.
:return: The returned value must be JSON-friendly.
�:)�implementationzmax-concurrency)� __class__�
__module__�__name__r% r- r r r! � _get_info� s �zBasePool._get_infoc C s | � � S r$ )rW r- r r r! �info� s z
BasePool.infoc C s | j | jkS r$ )rB rJ r- r r r! �active� s zBasePool.activec C s | j S r$ )r% r- r r r! �
num_processes� s zBasePool.num_processes)NTTr N)N)NN),rV rU � __qualname__�__doc__rJ rL rA r
�TimerZ signal_safeZis_greenrB �_poolrI Zuses_semaphoreZtask_join_will_blockZbody_can_be_bufferr, r. r/ r0 r1 r3 r5 r6 r8 r9 r: r? r@ rC rD rK rN rM rP r �strr rW �propertyrX rY rZ r r r r! r
/ sR �
r
) r\ rG �osr �time�typingr r Zbilliard.einfor Zbilliard.exceptionsr Zkombu.utils.encodingr Zcelery.exceptionsr r r Z celery.utilsr
Zcelery.utils.logr Zcelery.utils.textr �__all__rE r r r r
r r r r! �<module> s& �