
    `f                     N    d Z ddlZddlmZ ddlmZmZ dZ G d de          ZdS )	zSingle-threaded execution pool.    N)signals   )BasePoolapply_target)TaskPoolc                   0     e Zd ZdZdZ fdZ fdZ xZS )r   z(Solo task pool (blocking, inline, fast).Tc                      t                      j        |i | t          | _        d| _        t
          j                            d            d S )Nr   )sender)super__init__r   on_applylimitr   worker_process_initsend)selfargskwargs	__class__s      I/var/www/html/env/lib/python3.11/site-packages/celery/concurrency/solo.pyr   zTaskPool.__init__   sM    $)&)))$
#(((55555    c                     t                                                      }|                    dt          j                    gd ddd           |S )Nr   T )zmax-concurrency	processeszmax-tasks-per-childzput-guarded-by-semaphoretimeouts)r   	_get_infoupdateosgetpid)r   infor   s     r   r   zTaskPool._get_info   sV    ww  "" )++#'(,
 
 	 	 	 r   )__name__
__module____qualname____doc__body_can_be_bufferr   r   __classcell__)r   s   @r   r   r      s]        226 6 6 6 6	 	 	 	 	 	 	 	 	r   r   )	r#   r   celeryr   baser   r   __all__r   r   r   r   <module>r)      sw    % % 				       ( ( ( ( ( ( ( (
    x     r   