a hq@sBddlZddlmZddlmZeeZeddZddZ dS)N)contextmanager)castccsd}|r dnd}d|d|}||d|}||kr\dV||d||dqq z||gWq tytd||Yq 0q dS) NZRpcGroupManagementTokenjoinZleaveZ Token_for__DonezBGroup membership token %s timed out waiting for %s to be released.)Z compare_setdecodesetwait RuntimeErrorloggererror)storenameis_joinZ token_keyZ join_or_leaveZmy_tokenZreturnedrJ/var/www/auris/lib/python3.9/site-packages/torch/distributed/rpc/_utils.py_group_membership_management s$    rcCs2ddlm}m}t||}|||||}|S)N)apiTensorPipeAgent)rrrrZ_get_current_rpc_agent_update_group_membership)Z worker_infoZ my_devicesZreverse_device_maprrrZagentretrrrr(s r) logging contextlibrtypingr getLogger__name__r rrrrrrs