File: //usr/local/lib/python3.9/site-packages/celery/utils/__pycache__/nodenames.cpython-39.pyc
a
X>h[ � @ s$ d Z ddlmZ ddlZddlZddlmZ ddlmZm Z ddl
m Z ddl m
Z
ed �Zd
Zd Zd Ze ded
�ej�ZdZddd�dd�Zdddd�dd�Zd0dddd�dd �Zdd d �d d �Zddd�d!d"�Zddd#dd$�d%d&�Zd1dddd)�d*d+�Zeed,d'�Z d2dddd#dd-�d.d/�Z dS )3zWorker name utilities.� )� annotationsN)�partial)�Exchange�Queue� )�memoize)�
simple_formatzC.dq2z{hostname}.dq2�@Zcelery)�Cache)�
worker_direct� gethostname�nodename�
anon_nodename� nodesplit�default_nodename� node_format� host_formatz str | Queuer )�hostname�returnc C s" t | t�r| S ttj| d�t| �S )a5 Return the :class:`kombu.Queue` being a direct route to a worker.
Arguments:
hostname (str, ~kombu.Queue): The fully qualified node name of
a worker (e.g., ``[email protected]``). If passed a
:class:`kombu.Queue` instance it will simply return
that instead.
�r )�
isinstancer �WORKER_DIRECT_QUEUE_FORMAT�format�WORKER_DIRECT_EXCHANGEr � r �@/usr/local/lib/python3.9/site-packages/celery/utils/nodenames.pyr & s
�r �str)�namer r c C s t �| |f�S )z)Create node name from name/hostname pair.)� NODENAME_SEP�join)r r r r r r
8 s r
�genz
str | None)r �prefixr c C s" t d�|tt�� �g�| p t� �S )zsReturn the nodename for this process (not a worker).
This is used for e.g. the origin task message field.
� )r
r r �os�getpidr )r r! r r r r = s r z tuple[None, str] | list[str])r r c C s( | � td�}t|�dkr$d|d fS |S )z,Split node name into tuple of name/hostname.r Nr )�splitr �len)r �partsr r r r E s r c C s$ t | pd�\}}t|pt|p t� �S )z-Return the default nodename for this process.r" )r r
�NODENAME_DEFAULTr )r r �hostr r r r M s r �dict)�sr �extrar c K s( t |�\}}t| ||ptfd|i|��S )z(Format worker node name ([email protected]).�p)r r r( )r+ r r, � shortnamer) r r r r S s r r" �0)r! �defaultr c C s& ddl m} |� }|r"| � |� �S |S )Nr )�current_process_index)�logr1 )r! r0 r1 �indexr r r �_fmt_process_indexY s r4 �-)r+ r) r r, r c K sH |pt � }|�d�\}}}|p |}t|||ttd�fi |��}t| |�S )z Format host %x abbreviations.�.)�h�n�d�i�I)r � partitionr* r4 � _fmt_process_index_with_prefixr )r+ r) r r, �hname�_�domain�keysr r r r c s
���
r )Nr )r" r/ )NN) �__doc__�
__future__r r# �socket� functoolsr Z kombu.entityr r Z
functionalr �textr r r r r( r* r �__all__r r
r r r r r4 r= r r r r r �<module> s,