telemetry.manager
telemetry.manager
Telemetry manager and associated utilities.
Classes
| Name | Description |
|---|---|
| TelemetryManager | Manages telemetry collection and transmission |
TelemetryManager
telemetry.manager.TelemetryManager()Manages telemetry collection and transmission
Methods
| Name | Description |
|---|---|
| send_event | Send a telemetry event |
| send_system_info | Helper method for sending system info |
| shutdown | Ensure all queued events are processed before shutdown |
send_event
telemetry.manager.TelemetryManager.send_event(event_type, properties=None)Send a telemetry event
send_system_info
telemetry.manager.TelemetryManager.send_system_info()Helper method for sending system info
shutdown
telemetry.manager.TelemetryManager.shutdown()Ensure all queued events are processed before shutdown
Functions
| Name | Description |
|---|---|
| is_main_process | Check whether we’re running in the main process. |
is_main_process
telemetry.manager.is_main_process()Check whether we’re running in the main process.
Note
We’re using this function instead of torch.utils.distributed.is_main_process
causes issues with DeepSpeed world_size since. This function avoids that issue
by checking env vars that are set by various launchers.
Returns
| Name | Type | Description |
|---|---|---|
| bool | Whether we’re running in the main process. |