File: //home/arjun/projects/env/lib/python3.10/site-packages/celery/__pycache__/__init__.cpython-310.pyc
o
-we= �
@ sD d Z ddlZddlZddlZddlmZ ddlmZ dZdZ dZ
d Z d
Z d Z
d Zd
Ze � de� d�Zedd�Ze�de ��� Zeeed �eed �eed �ed pTdd� ZZ[[ej�d�rsddlZddddejfdd�Z e e_dZ de � d ddd� � � < e r�dd l m!Z!m"Z" dd l#m$Z$ dd l%m&Z& dd l'm(Z( dd!l)m*Z* dd"l+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4 dd#l5m6Z6 dCd$d%�Z7d&d'� Z8d(d)� Z9 dDd*d+�Z:ej;e<fi d,g d-�d.gd/d0gg d1�d2gd3��d4d5�d6e=�d7e>�d8e �d9e �d:e
�d;e �d<e �d=e
�d>e�d?e�d@e�dAe�de�dBe�d+e:�d%e7��\Z?Z@dS )EzDistributed Task Queue.� N)�
namedtuple� )�localz emerald-rushz5.3.6z Ask Solemzauvipy@gmail.comzhttps://docs.celeryq.dev/�restructuredtextz*task job queue distributed messaging actor)�Celery� bugreport� shared_task�Task� current_app� current_task�maybe_signature�chain�chord�chunks�group� signature�xmap�xstarmap�uuidz (�)�version_info_t)�major�minor�micro� releaselevel�serialz(\d+)\.(\d+).(\d+)(.+)?� � � �
C_IMPDEBUG���c C sT |pt tdd d d� �d�j}|r|�d�pd}td|� d| � �� || ||||�S )N� emarfteg_r r �__name__�unknownz-- z imports )�getattr�sys� f_globals�get�print)�name�locals�globals�fromlist�level� real_import�glob�
importer_name� r1 �H/home/arjun/projects/env/lib/python3.10/site-packages/celery/__init__.py� debug_import6 s r3 TF� kcah_acitats)r
r )r )r )r )r ) r
r r r r r �subtaskr r )r c C s� t | �D ]8\}}|�d�r<|r.|�d�r.|�d�\}}}||v r.|r&| S | |d S |r<||v r<| |d S qtd�|pGg | pGg ���)z�Search argv for options specifying short and longopt alternatives.
Returns:
str: value for option found
Raises:
KeyError: if option not found.
�-z--�=r �|)� enumerate�
startswith� partition�KeyError�join)�argv�
short_opts� long_opts�i�argr) �sep�valr1 r1 r2 �_find_option_with_argQ s
�rE c C s< dd l } | �� ttj�dd��}|r | j�||� d S d S )Nr �EVENTLET_NOBLOCK)�eventlet.debug� monkey_patch�float�os�environr' �debug�hub_blocking_detection)�eventlet� blockdetectr1 r1 r2 �_patch_eventletd s �rP c C s dd l } dd l} | j�� d S )Nr )�
gevent.monkey�
gevent.signal�monkey� patch_all)�geventr1 r1 r2 �
_patch_geventm s rV c C s� | r| nt j} |r |ndg}|r|ndg}|r|nttd�}zt| ||�}W n
ty0 Y dS w z|| }W n ty@ Y nw |� ddlm} ||�� v rW|� |� dS dS )a Apply eventlet/gevent monkeypatches.
With short and long opt alternatives that specify the command line
option to set the pool, this makes sure that anything that needs
to be patched is completed as early as possible.
(e.g., eventlet/gevent monkey patches).
z-Pz--pool)rN rU r )� concurrencyN)
r% r> rP rV rE r< �celeryrW �get_available_pool_names�get_implementation)r> r? r@ �patches�pool�patcherrW r1 r1 r2 �maybe_patch_concurrencyt s*
� � � �r^ � by_module)r r r r r
r )
� Signaturer
r r r r r r5 r r r )z
celery.appzcelery.app.taskz
celery._statez
celery.canvasz celery.utils� __package__rX �__file__�__path__�__doc__� __version__�
__author__� __contact__� __homepage__�
__docformat__r �VERSION�SERIES�VERSION_BANNER� version_info)NN)NNNN)Ard rJ �rer% � collectionsr r r rk re rf rg rh ri � __keywords__�__all__rl r �match�groups�_temp�intrj rm rK r' �builtins�
__import__r3 � STATICA_HACKr+ �upper�
celery._stater
r �
celery.appr �celery.app.baser �celery.app.taskr �celery.app.utilsr �
celery.canvasr
r r r r r r5 r r � celery.utilsr rE rP rV r^ �recreate_moduler" rb rc �
old_module�
new_moduler1 r1 r1 r2 �<module> s�
��*�
� ,
�"���
�
��������������� �