|
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 dZG dd� de�ZdS ) zSingle-threaded execution pool.� N)�signals� )�BasePool�apply_target)�TaskPoolc s0 e Zd ZdZdZ� fdd�Z� fdd�Z� ZS )r z(Solo task pool (blocking, inline, fast).Tc s0 t � j|i |�� t| _d| _tjjd d� d S )Nr )Zsender)�super�__init__r Zon_apply�limitr Zworker_process_init�send)�self�args�kwargs�� __class__� �A/usr/local/lib/python3.9/site-packages/celery/concurrency/solo.pyr s zTaskPool.__init__c s* t � �� }|�dt�� gd ddd�� |S )Nr Tr )zmax-concurrencyZ processeszmax-tasks-per-childzput-guarded-by-semaphoreZtimeouts)r � _get_info�update�os�getpid)r �infor r r r s
�zTaskPool._get_info)�__name__�
__module__�__qualname__�__doc__Zbody_can_be_bufferr r �
__classcell__r r r r r s r ) r r Zceleryr �baser r �__all__r r r r r �<module> s