Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/concurrency/__pycache__/base.cpython-39.pyc
Ðазад
a t�hb � @ 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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& �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка