g^(hmnddlZddlmZddlmZddlmZmZeje Z edZ dZ y)N)contextmanager)cast)apiTensorPipeAgentc#<Kd}|rdnd}d|d|} |j|d|j}||k(r)d|j|d|j|dy |j|gc#t$rt j d||wxYww) NRpcGroupManagementTokenjoinleave Token_for__DonezBGroup membership token %s timed out waiting for %s to be released.) compare_setdecodesetwait RuntimeErrorloggererror)storenameis_join token_key join_or_leavemy_tokenreturneds Z/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/torch/distributed/rpc/_utils.py_group_membership_managementr s)I%F7MD6=/2H $$YH=DDF x   IIi $ IIh '   H:&     X   sA!B$A76B7"BBcrtttj}|j ||||}|S)N)rrr_get_current_rpc_agent_update_group_membership) worker_info my_devicesreverse_device_mapragentrets rr"r"*s8 #"<"<"> ?E  ( (Z!3W C J) logging contextlibrtypingrrrr getLogger__name__rrr"r(rr/s>%"   8 $:r(