
    h                         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<   	 ej                  j                  d      Zeed<   d Zd Zy# e$ r Y /w xY w# e$ r Y w xY w)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    W/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/concurrency/__init__.pyr   r   )   s    #w''    c                  <    t        t        j                               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 	
 /
= 562.6> >GIZZ^^78F GH(
!3  		  		s"   A	 A 	AAAA