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/worker/__pycache__/ |
a
��Sh�! � @ sH d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
Z
m Z ddl m
Z
ddlmZ ddlmZmZ ddlmZ d Zd
ee�� d �Zeej�d d
��Zeej�dd��Z e ej�dd��Z e ej�dd��Z i Z e�!� Z"e�!� Z#ee e d�Z$e� Z%dgZ&eee d�Z'i Z(dZ)dZ*dd� Z+dd� Z,e j-e"j.fdd�Z/de j-e#j.e%j0fdd�Z1d e j2e#j3e"j3fd d �Z4ej�d ��p�ej�d �Z5eej�d!��p�ej�d"��p�d�Z6e5�r6ddl7Z7dd#l8m9Z9 dd$l:m;Z; dd%l<m=Z=m>Z> da?da@daAdaBe6ZCg ZDe/ZEe4ZFe;� jGd&k�r&e7jHd'd(� �ZId)d� Z/d*d � Z4G d+d,� d,�ZJdS )-zwInternal worker state (global).
This includes the currently active and reserved tasks,
statistics, and revoked tasks.
� N)�Counter)�pickle�pickle_protocol)�cached_property)� __version__)�WorkerShutdown�WorkerTerminate)�
LimitedSet)
�
SOFTWARE_INFO�reserved_requests�active_requests� total_count�revoked�
task_reserved�maybe_shutdown�
task_accepted�
task_ready�
Persistentz py-celery)Zsw_identZsw_verZsw_sysZCELERY_WORKER_REVOKES_MAXiP� Z CELERY_WORKER_SUCCESSFUL_MAXi� Z CELERY_WORKER_REVOKE_EXPIRESi0* Z CELERY_WORKER_SUCCESSFUL_EXPIRES)�maxlen�expiresc C sJ t �� t�� t�� t�� t�� dgtd d �< t�� t�� d S )Nr ) �requests�clearr r �successful_requestsr
�all_total_countr �revoked_stamps� r r �=/usr/local/lib/python3.9/site-packages/celery/worker/state.py� reset_stateM s r c C s6 t durt durtt ��ntdur2tdur2tt��dS )z Shutdown if flags have been set.NF)�should_terminater � should_stopr r r r r r X s
r c C s || j | � || � dS )z2Update global state when a task has been reserved.N)�id)�request� add_requestZadd_reserved_requestr r r r ` s r c C s> |st }|| j| � || � || jdi� t d d7 < dS )z2Update global state when a task has been accepted.� r N)r r �name)r! Z_all_total_countr" Zadd_active_requestZadd_to_total_countr r r r h s r Fc C s0 |rt �| j� || jd� || � || � dS )z)Update global state when a task is ready.N)r �addr )r! Z
successfulZremove_requestZdiscard_active_requestZdiscard_reserved_requestr r r r v s
r �C_BENCHZ CELERY_BENCH�
C_BENCH_EVERYZCELERY_BENCH_EVERY)� monotonic)�current_process)�memdump�
sample_mem� MainProcessc C sF t d urBtd urBtd�tt �� td�tt�tt� �� t� d S )Nz - Time spent in benchmark: {!r}z - Avg: {})� bench_first�
bench_last�print�format�sum� bench_sample�lenr* r r r r � on_shutdown� s ��r4 c C s* d}t du rt� a }tdu r"|at| �S )z-Called when a task is reserved by the worker.N)� bench_startr( r- �
__reserved)r! �nowr r r r � s
c C sX t d7 a t t sPt� }|t }td�t|�� tj�� | aa t
� |� t � t
| �S )z Called when a task is completed.r# zG- Time spent processing {} tasks (since first task received): ~{:.4f}s
)� all_count� bench_everyr( r5 r/ r0 �sys�stdout�flushr. r2 �appendr+ �__ready)r! r7 �diffr r r r � s �
c @ s� e Zd ZdZeZeZej Z ej
Z
dZ d$dd�Z dd� Z
dd � Zd
d � Zd d
� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zed d!� �Ze d"d#� �Z dS )%r z�Stores worker state between restarts.
This is the persistent data stored by the worker when
:option:`celery worker --statedb` is enabled.
Currently only stores revoked task id's.
FNc C s || _ || _|| _| �� d S �N)�state�filename�clock�merge)�selfrA rB rC r r r �__init__� s zPersistent.__init__c C s | j j| j| jdd�S )NT)�protocolZ writeback)�storage�openrB rG �rE r r r rI � s
�zPersistent.openc C s | � | j� d S r@ )� _merge_with�dbrJ r r r rD � s zPersistent.mergec C s | � | j� | j�� d S r@ )�
_sync_withrL �syncrJ r r r rN � s zPersistent.syncc C s | j r| j�� d| _ d S )NF)�_is_openrL �closerJ r r r rP � s
zPersistent.closec C s | � � | �� d S r@ )rN rP rJ r r r �save� s zPersistent.savec C s | � |� | �|� |S r@ )�_merge_revoked� _merge_clock�rE �dr r r rK � s
zPersistent._merge_withc C s> | j �� |�d| �| �| j ��| jr0| j�� ndd�� |S )N� r )Z __proto__�zrevokedrC )�_revoked_tasks�purge�update�compress�_dumpsrC ZforwardrT r r r rM � s
�zPersistent._sync_withc C s$ | j r | j �|�d�pd�|d< d S )NrC r )rC �adjust�getrT r r r rS � s zPersistent._merge_clockc C s\ z| � |d � W n: tyL z| �|�d�� W n tyF Y n0 Y n0 | j�� d S )NrW r )�_merge_revoked_v3�KeyError�_merge_revoked_v2�poprX rY rT r r r rR � s zPersistent._merge_revokedc C s |r | j �t�| �|��� d S r@ )rX rZ r �loads�
decompress)rE rW r r r r_ s z Persistent._merge_revoked_v3c C s$ t |t�s| �|�S | j�|� d S r@ )�
isinstancer �_merge_revoked_v1rX rZ )rE �savedr r r ra s
z Persistent._merge_revoked_v2c C s | j j}|D ] }||� q d S r@ )rX r% )rE rg r% �itemr r r rf s z Persistent._merge_revoked_v1c C s t j|| jd�S )N)rG )r �dumpsrG )rE �objr r r r\ s zPersistent._dumpsc C s | j jS r@ )rA r rJ r r r rX s zPersistent._revoked_tasksc C s d| _ | �� S )NT)rO rI rJ r r r rL s z
Persistent.db)N) �__name__�
__module__� __qualname__�__doc__�shelverH r rG �zlibr[ rd rO rF rI rD rN rP rQ rK rM rS rR r_ ra rf r\ �propertyrX r rL r r r r r � s0
r )Krn �os�platformro r: �weakrefrp � collectionsr Zkombu.serializationr r Zkombu.utils.objectsr Zceleryr Zcelery.exceptionsr r Zcelery.utils.collectionsr �__all__�systemr
�int�environr^ Z REVOKES_MAXZSUCCESSFUL_MAX�floatZREVOKE_EXPIRESZSUCCESSFUL_EXPIRESr �WeakSetr r r r
r r r r r r r � __setitem__r% r rZ r rb �discardr r& r' �atexit�timer( Zbilliard.processr) Zcelery.utils.debugr* r+ r8 r- r5 r. r9 r2 r6 r> �_name�registerr4 r r r r r �<module> s� �� �
�
�
��