o
    ©D®f±  ã                   @   s”   d Z ddlZddlmZ dZdddddd	œZzddlZW n	 ey%   Y nw d
ed< zej	 
d¡ZW n	 ey;   Y nw eed< dd„ Zdd„ ZdS )z<Pool implementation abstract factory, and alias definitions.é    N)Úsymbol_by_name)Úget_implementationÚget_available_pool_namesz#celery.concurrency.prefork:TaskPoolz$celery.concurrency.eventlet:TaskPoolz"celery.concurrency.gevent:TaskPoolz celery.concurrency.solo:TaskPool)ÚpreforkÚeventletÚgeventÚsoloÚ	processesz"celery.concurrency.thread:TaskPoolÚthreadsÚCELERY_CUSTOM_WORKER_POOLÚcustomc                 C   s
   t | tƒS )z#Return pool implementation by name.)r   ÚALIASES)Úcls© r   úT/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/concurrency/__init__.pyr   )   s   
r   c                   C   s   t t ¡ ƒS )z%Return all available pool type names.)Útupler   Úkeysr   r   r   r   r   .   s   r   )Ú__doc__ÚosÚkombu.utils.importsr   Ú__all__r   Úconcurrent.futuresÚ
concurrentÚImportErrorÚenvironÚgetr   ÚKeyErrorr   r   r   r   r   r   Ú<module>   s0    ûÿ	ÿ