События

Создано: May 04, 2021 | Последнее обновление: May 11, 2026

Модуль содержит механизмы обработки событий, интегрированные со стандартным модулем ведения журнала Python.

Пример использования:

from torch.distributed.elastic import events

event = events.Event(
    name="test_event", source=events.EventSource.WORKER, metadata={...}
)
events.get_logging_handler(destination="console").info(event)

Методы API

torch.distributed.elastic.events.record(event, destination='null') [исходный код]

torch.distributed.elastic.events.construct_and_record_rdzv_event(run_id, message, node_state, name='', hostname='', pid=None, master_endpoint='', local_id=None, rank=None) [исходный код]

Инициализирует объект события rendezvous и записывает выполняемые операции.

Параметры:

run_id (str) – Идентификатор запуска rendezvous.
message (str) – Сообщение с описанием события.
node_state (NodeState) – Состояние узла (INIT, RUNNING, SUCCEEDED, FAILED).
name (str) – Имя события (например, выполняемое в данный момент действие).
hostname (str) – Имя хоста узла.
pid (Optional[int]) – Идентификатор процесса узла.
master_endpoint (str) – Конечная точка ведущего узла для хранилища rendezvous, если она известна.
local_id (Optional[int]) – local_id узла, если он задан в dynamic_rendezvous.py
rank (Optional[int]) – Ранг узла, если он известен.

Возвращает:

None

Тип возвращаемого значения:

None

Пример

>>> # See DynamicRendezvousHandler class
>>> def _record(
...     self,
...     message: str,
...     node_state: NodeState = NodeState.RUNNING,
...     rank: Optional[int] = None,
... ) -> None:
...     construct_and_record_rdzv_event(
...         name=f"{self.__class__.__name__}.{get_method_name()}",
...         run_id=self._settings.run_id,
...         message=message,
...         node_state=node_state,
...         hostname=self._this_node.addr,
...         pid=self._this_node.pid,
...         local_id=self._this_node.local_id,
...         rank=rank,
...     )

torch.distributed.elastic.events.get_logging_handler(destination='null') [исходный код]

Тип возвращаемого значения:: Handler

torch.distributed.elastic.events.record_rdzv_event(event) [исходный код]

Объекты событий

class torch.distributed.elastic.events.api.Event(name, source, timestamp=0, metadata=<factory>) [исходный код]

Класс представляет общее событие, возникающее во время выполнения задания torchelastic.

Событием может быть любое значимое действие.

Параметры:

name (str) – имя события.
source (EventSource) – источник события, например агент или рабочий процесс.
timestamp (int) – временная метка в миллисекундах, указывающая, когда произошло событие.
metadata (dict[str, str | int | float | bool | None]) – дополнительные данные, связанные с событием.

class torch.distributed.elastic.events.api.EventSource(value) [исходный код]: Известные идентификаторы источников событий.

torch.distributed.elastic.events.api.EventMetadataValue: псевдоним для str | int | float | bool | None

class torch.distributed.elastic.events.api.NodeState(value) [исходный код]: Состояния, в которых может находиться узел в rendezvous.

© 2026, PyTorch Contributors
PyTorch has a BSD-style license, as found in the LICENSE file.
https://docs.pytorch.org/docs/2.14/elastic/events.html