configs.streaming.get_streamer#
- configs.streaming.get_streamer(source, component, state=None)[source]#
Get a stream writer for consistent streaming events.
Parallels the get_logger() pattern for familiar usage.
- Parameters:
source (str) – Source type (e.g., “framework”, “als_expert”)
component (str) – Component name (e.g., “orchestrator”, “python_executor”)
state (Any | None) – Optional AgentState for extracting execution context
- Returns:
StreamWriter instance that handles event emission automatically
- Return type:
Example
streamer = get_streamer(“framework”, “orchestrator”, state) streamer.status(“Creating execution plan…”) streamer.success(“Plan created”)