PreemptionInfo

class ray.train.PreemptionInfo(deadline_ms: int | None, preempted_node_to_ranks: Dict[str, List[int]])

Bases: object

Information about an imminent preemption event.

deadline_ms

Earliest preemption deadline (UNIX time in milliseconds) across all preempted nodes. None if no deadline was reported.

Type:

int | None

preempted_node_to_ranks

Map of each preempted node_id to the affected worker world ranks when that node is preempted.

Type:

Dict[str, List[int]]

PublicAPI (alpha): This API is in alpha and may change before becoming stable.

property preempted_node_ids: List[str]

Preempted node IDs, sorted lexicographically.

property preempted_ranks: List[int]

All affected ranks across the preempted nodes, sorted ascending.