BVh(ldZddlZddlmZddlmZddlmZdZ dZ edGd d e Z y) zCDefines the `Topology` class, that describes a TPU fabric topology.N) topology_pb2) numpy_compat) tf_exportc$|d||fzSd|||fzS)z@Returns the device name for the TPU `device` on `task` of `job`.z/task:%d/device:TPU:%dz/job:%s/task:%d/device:TPU:%d)jobtaskdevices N/home/dcms/DCMS/lib/python3.12/site-packages/tensorflow/python/tpu/topology.py_tpu_device_namer s([ #tVn 44 *c4-@ @@c|d|zSd||fzS)z>Returns the device name for the CPU device on `task` of `job`.z/task:%d/device:CPU:0z/job:%s/task:%d/device:CPU:0r)rr s r _tpu_host_device_namer s![ "T )) )S$K 77r ztpu.experimental.TopologyceZdZdZddZdZdZedZedZ edZ ed Z d Z d Z dd Zdd ZedZedZdZy)TopologyzDescribes a set of TPU devices. Represents both the shape of the physical mesh, and the mapping between TensorFlow TPU devices to physical mesh coordinates. Nc ||_|r|j|nqtj|tj |_tj|tj |_t|j dk7st|j dkrtd|j dt|jjdk7s/|jjdt|j k7rtdj|jjt|jj|jjd|j t|j |j\|_|_t j |jd k|_y ) a(Builds a Topology object. If `serialized` is not `None`, the topology is parsed from `serialized` and the other arguments are ignored. Otherwise, the topology is computed from `mesh_shape` and `device_coordinates`. Args: serialized: A serialized `TopologyProto`, or `None`. If not `None`, the serialized proto is parsed to discover the topology. mesh_shape: A sequence of 4 positive integers, or `None`. If not `None`, the shape of the TPU topology, in number of cores. Ignored if `serialized` is not `None`. device_coordinates: A rank 3 numpy array that describes the mapping from TensorFlow TPU devices to TPU fabric coordinates, or `None`. If specified, array is a rank 3 int32 array with shape `[tasks, devices, axis]`. `tasks` is the number of tasks in the TPU cluster, `devices` is the number of TPU devices per task, and `axis` is the number of axes in the TPU cluster topology. Each entry gives the `axis`-th coordinate in the topology of a task/device pair. TPU topologies are 4-dimensional, with dimensions `(x, y, z, core number)`. This arg is ignored if `serialized is not `None`. Raises: ValueError: If `serialized` does not describe a well-formed topology. ValueError: If `serialized` is `None` and `mesh_shape` is not a sequence of 4 positive integers. ValueError: If `serialized` is `None` and `device_coordinates` is not a rank 3 numpy int32 array that describes a valid coordinate mapping. dtypezG`mesh_shape` must be a sequence of 4 positive entries; got `mesh_shape=`z`device_coordinates` must be a rank 3 int32 array with minor dimension equal to the `mesh_shape` rankgot device_coordinates.shape={} len(device_coordinates.shape)={} device_coordinates.shape[2]={} mesh_shape={}, len(mesh_shape)={}rN) _serialized_parse_topologyr np_asarraynpint32 _mesh_shape_device_coordinateslenany ValueErrorshapeformat_invert_topology_topology_tasks_topology_devicesargwhere_missing_devices)self serialized mesh_shapedevice_coordinatess r __init__zTopology.__init__0s>"D :&%00288Ld!-!8!89K?Axx"Id T   ! #s4+;+;a+?'@5595E5E4FaIJ J d&&,, - 2  " " ( ( +s43C3C/D D PVD,,2200667,,2215t7G7G(()+ , ,483H3H3J0D$0KK(<(= 0; got {}z/`num_tpu_devices_per_task` must be >= 0; got {}zx`device_coordinates` must have shape num_tasks ({}) * num_tpu_devices_per_task ({}) * len(mesh_shape) ({}); got shape {}z7All values in `device_coordinates` must be >= 0, got {}N)r TopologyProtoParseFromStringrarrayr-rrr!r"r#r% num_tasksnum_tpu_devices_per_taskr.reshaper )r+r,protoexpected_coordinates_sizecoordss r rzTopology._parse_topologyks  & & (E *%xx 0 0AD 4  !S)9)9A)=%> ))/0@0@)A CC  9@@ //  %%) HOO  ( (* ++ %8883   <  5 # #$(AA &&,fU__-2-K-K-2-=-=-01I1I-J'L MMXXe..bhh ?F 6A:  C 6&> ^^U__e.L.L !1!1245F%Dr ctjt|jdtj}tjt|jdtj}t |j jdD]T}t |j jdD]-}|j ||ddf\}}}}||||||f<||||||f</V||fS)zEInverts a [task,device,axis] topology to [x,y,z] -> task/device maps.rrrN)rfulllistr-rranger.r$) r+tasksdevicesr r xyzcores r r&zTopology._invert_topologys GGD)2RXX >Eggd4??+Rrxx@Gd--33A67($1177:;(&//fa@ 1a#aAtm!'1a (( '>r c|jS)z>A rank 1 int32 array describing the shape of the TPU topology.)rr+s r r-zTopology.mesh_shapes   r c,t|jS)z-Returns the number of dimensions in the mesh.)r!rrFs r mesh_rankzTopology.mesh_ranks t  r c|jS)aDescribes the mapping from TPU devices to topology coordinates. Returns: A rank 3 int32 array with shape `[tasks, devices, axis]`. `tasks` is the number of tasks in the TPU cluster, `devices` is the number of TPU devices per task, and `axis` is the number of axes in the TPU cluster topology. Each entry gives the `axis`-th coordinate in the topology of a task/device pair. TPU topologies are 4-dimensional, with dimensions `(x, y, z, core number)`. )r rFs r r.zTopology.device_coordinatess  # ##r c|jS)z$Array of indices of missing devices.)r*rFs r missing_deviceszTopology.missing_devicess   r c2|jt|S)aCReturns the TensorFlow task number attached to `device_coordinates`. Args: device_coordinates: An integer sequence describing a device's physical coordinates in the TPU fabric. Returns: Returns the TensorFlow task number that contains the TPU device with those physical coordinates. )r'tupler+r.s r task_ordinal_at_coordinatesz$Topology.task_ordinal_at_coordinatess   &8 9 ::r c2|jt|S)aYReturns the TensorFlow device number at `device_coordinates`. Args: device_coordinates: An integer sequence describing a device's physical coordinates in the TPU fabric. Returns: Returns the TensorFlow device number within the task corresponding to attached to the device with those physical coordinates. )r(rMrNs r !tpu_device_ordinal_at_coordinatesz*Topology.tpu_device_ordinal_at_coordinatess  ! !%(:"; <>r ctt||jt||jt|S)z>Returns the name of the TPU device assigned to a logical core.)r r'rMr(rSs r tpu_device_name_at_coordinatesz'Topology.tpu_device_name_at_coordinatess; C 007I1JK 2259K3LM OOr c4|jjdS)z8Returns the number of TensorFlow tasks in the TPU slice.rr r$rFs r r4zTopology.num_tasks  # # ) )! ,,r c4|jjdS)z O  - - - - r r) rcnumpyrtensorflow.core.protobuf.tpurtensorflow.python.utilr tensorflow.python.util.tf_exportrr robjectrrr r rjsFJ5/6A8 &'HvH(Hr