o
    h                     @   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   ]/var/www/html/optinet_system/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    	