stormlog.timeline_markers

Derived timeline marker helpers for telemetry sessions.

Functions

`derive_session_timeline_markers`(session, *)	Derive normalized markers from one loaded telemetry session.
`derive_timeline_markers`(events, *[, ...])	Derive normalized timeline markers from telemetry events.
`timeline_marker_to_dict`(marker)	Serialize a marker into a JSON-safe mapping.

Classes

TimelineMarker(session_id, start_ns, end_ns, ...)

Normalized timeline landmark derived from telemetry or annotation sources.

class stormlog.timeline_markers.TimelineMarker(session_id, start_ns, end_ns, kind, source, severity, label, rank=None, local_rank=None, world_size=None, event_type=None, metadata=<factory>)[source]

Bases: object

Normalized timeline landmark derived from telemetry or annotation sources.

Parameters:

session_id (str)
start_ns (int)
end_ns (int | None)
kind (str)
source (str)
severity (str)
label (str)
rank (int | None)
local_rank (int | None)
world_size (int | None)
event_type (str | None)
metadata (dict[str, Any])

session_id: str

start_ns: int

end_ns: int | None

kind: str

source: str

severity: str

label: str

rank: int | None = None

local_rank: int | None = None

world_size: int | None = None

event_type: str | None = None

metadata: dict[str, Any]

property is_interval: bool: Return whether the marker spans a non-point interval.

stormlog.timeline_markers.derive_session_timeline_markers(session, *, include_phase_markers=True)[source]

Derive normalized markers from one loaded telemetry session.

Parameters:

session (LoadedTelemetrySession)
include_phase_markers (bool)

Return type:

list[TimelineMarker]

stormlog.timeline_markers.derive_timeline_markers(events, *, include_phase_markers=True)[source]

Derive normalized timeline markers from telemetry events.

Parameters:

events (Sequence[Any])
include_phase_markers (bool)

Return type:

list[TimelineMarker]

stormlog.timeline_markers.timeline_marker_to_dict(marker)[source]

Serialize a marker into a JSON-safe mapping.

Parameters:: marker (TimelineMarker)
Return type:: dict[str, Any]