Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/__pycache__/state.cpython-39.pyc
Ðазад
a t�h�! � @ 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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 �forwardrT 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 rb s z Persistent._merge_revoked_v2c C s | j j}|D ] }||� q d S r@ )rX r% )rE rh r% �itemr r r rg 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[ re rO rF rI rD rN rP rQ rK rM rS rR r` rb rg r\ �propertyrX r rL r r r r r � s0 r )Kro �os�platformrp r: �weakrefrq � 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 rc �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� �� � � � ��
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка