
    h                     F    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y)	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        |   |i | t        | _        d| _        t
        j                  j                  d        y )Nr   )sender)super__init__r   on_applylimitr   worker_process_initsend)selfargskwargs	__class__s      S/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/concurrency/solo.pyr   zTaskPool.__init__   s:    $)&)$
##(((5    c                 x    t         |          }|j                  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   s?    w " ))+#'(,
 	 r   )__name__
__module____qualname____doc__body_can_be_bufferr   r   __classcell__)r   s   @r   r   r      s    26	 	r   r   )	r#   r   celeryr   baser   r   __all__r   r   r   r   <module>r)      s"    % 	  (
x r   