o ;iD @sUddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z eGdd d Zdaeeed <d efd d Zde dedefddZeeZdS)N) dataclass)Optional)synchronize_api)_Client) InvalidError)api_pb2c@s6eZdZUeed<eed<eeed<eeed<dS) ClusterInforank cluster_id container_ipscontainer_ipv4_ipsN)__name__ __module__ __qualname__int__annotations__strlistrrN/home/ubuntu/.local/lib/python3.10/site-packages/modal/_clustered_functions.pyr s  r cluster_inforeturncCstdurtdtS)NznCluster info not initialized. Please ensure that you are calling get_cluster_info() from a clustered function.)rrrrrrget_cluster_infos rclienttask_id world_sizecsdd}t}|}||tjd<tjddvr'dtjd<dtjd <ntjdd kr9d tjd<d tjd <n dtjd<dtjd <|d krc|jtj||dIdH}t|j |j |j |j da dStdd|ggda dS)NcSstddtjdddS)z4Returns the ipv6 address assigned to this container.zi6pn.modal.localNr)socket getaddrinfoAF_INET6rrrrget_i6pn$sz0_initialize_clustered_function..get_i6pn NCCL_HOSTIDMODAL_CLOUD_PROVIDER)CLOUD_PROVIDER_GCPCLOUD_PROVIDER_OCI4NCCL_SOCKET_NTHREADS1NCCL_NSOCKS_PERTHREADCLOUD_PROVIDER_AWS28)r container_ip)r r r r r)r gethostnameosenvironstubTaskClusterHellorTaskClusterHelloRequestr cluster_rankr r r r)rrrr hostnamer-resprrr_initialize_clustered_function!s@         r8)r0r dataclassesrtypingrmodal._utils.async_utilsr modal.clientrmodal.exceptionr modal_protorrrrrrrr8initialize_clustered_functionrrrrs        3