o
    Zhm                     @   sR   d dl Z d dlmZ d dlmZ ddlmZmZ e e	Z
edd Zdd	 ZdS )
    N)contextmanager)cast   )apiTensorPipeAgentc                 c   s    d}|rdnd}d| d| }	 |  |d| }||kr0d V  | |d | |d d S z| |g W n tyG   td	||  w q)
NZRpcGroupManagementTokenjoinZleaveZ
Token_for__T DonezBGroup membership token %s timed out waiting for %s to be released.)Zcompare_setdecodesetwaitRuntimeErrorloggererror)storenameis_joinZ	token_keyZjoin_or_leaveZmy_tokenreturned r   K/var/www/auris/lib/python3.10/site-packages/torch/distributed/rpc/_utils.py_group_membership_management   s,   r   c                 C   s"   t tt }|| |||}|S )N)r   r   r   Z_get_current_rpc_agent_update_group_membership)Zworker_infoZ
my_devicesZreverse_device_mapr   Zagentretr   r   r   r   *   s
   r   )logging
contextlibr   typingr   r	   r   r   	getLogger__name__r   r   r   r   r   r   r   <module>   s   

