事件

模块包含与标准 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.get_logging_handler(destination='null')

返回类型

处理程序

事件对象

class torch.distributed.elastic.events.api.Event(name, source, timestamp=0, metadata=<factory>)

该类表示在 torchelastic 作业执行期间发生的通用事件。

事件可以是任何有意义的操作。

参数

• name (str) – 事件名称。

• source (EventSource) – 事件生产者，例如代理或工作器

• timestamp (int) – 事件发生时的毫秒级时间戳。

• metadata (Dict[str, Optional[Union[str, int, float, bool]]]) – 与事件关联的附加数据。

class torch.distributed.elastic.events.api.EventSource(value)

事件生产者的已知标识符。

torch.distributed.elastic.events.api.EventMetadataValue

Optional[Union[str, int, float, bool]] 的别名