yera.runtime.replay_executor

Provides the ReplayExecutor for replaying session events.

Symbols

class ReplayExecutor — Executor that replays stored events for a specific session.

ReplayExecutor

Inherits: PyRuntimeExecutor

Executor that replays stored events for a specific session.

Methods

start — Starts the event replay process in a separate spawn process.

stop — Stop the app process if it is running and clean up resources.

make_factory_fn — ...

ReplayExecutor.start

start() → None

Starts the event replay process in a separate spawn process.

ReplayExecutor.stop

stop() → None

Stop the app process if it is running and clean up resources.

ReplayExecutor.make_factory_fn

make_factory_fn(
    session_sources: str | dict[str, str],
    session_store_root: Path | None = None,
) → Callable[[AppFunctionWrapper, tuple, dict, str], PyRuntimeExecutor]

...

Parameters

session_sources

type: str | dict[str, str]

Either a single source session_id to replay for ANY live session that gets launched (the common case — one server, one canned transcript), or a dict mapping live session_id -> source session_id for servers that multiplex several concurrent sessions against different transcripts.

session_store_root

type: Path | None = None

directory to use as storage location for session store.