o
    Df                     @   s@   d Z ddlZddlmZ ddlmZmZ dZG dd deZdS )	zSingle-threaded execution pool.    N)signals   )BasePoolapply_target)TaskPoolc                       s0   e Zd ZdZdZ fddZ fddZ  ZS )r   z(Solo task pool (blocking, inline, fast).Tc                    s0   t  j|i | t| _d| _tjjd d d S )Nr   )sender)super__init__r   on_applylimitr   worker_process_initsend)selfargskwargs	__class__ P/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/concurrency/solo.pyr	      s   zTaskPool.__init__c                    s*   t   }|dt gd ddd |S )Nr   Tr   )zmax-concurrency	processeszmax-tasks-per-childzput-guarded-by-semaphoretimeouts)r   	_get_infoupdateosgetpid)r   infor   r   r   r      s   
zTaskPool._get_info)__name__
__module____qualname____doc__body_can_be_bufferr	   r   __classcell__r   r   r   r   r      s
    r   )	r   r   celeryr   baser   r   __all__r   r   r   r   r   <module>   s    