
    `f                         d Z ddlZddlmZ dZdddddd	Z	 ddlZd
ed<   n# e$ r Y nw xY w	 ej	        
                    d          Zeed<   n# e$ r Y nw xY wd Z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                 ,    t          | t                    S )z#Return pool implementation by name.)r   ALIASES)clss    M/var/www/html/env/lib/python3.11/site-packages/celery/concurrency/__init__.pyr   r   )   s    #w'''    c                  N    t          t                                                    S )z%Return all available pool type names.)tupler   keys r   r   r   r   .   s       r   )__doc__oskombu.utils.importsr   __all__r   concurrent.futures
concurrentImportErrorenvirongetr   KeyErrorr   r   r   r   r   <module>r!      s    B B 				
 / . . . . .
= 562.6 > >GI  	 	 	D	Z^^788F GH  	 	 	D	( ( (
! ! ! ! !s   " **A AA