INNER CODE UNIT · Python

_stream_plan

genome-spy/genome-spy · packages/app-agent/server/app/main.py:209

async def _stream_plan(
    provider_request: ProviderRequest,
    settings: Settings,
    *,
    estimated_input_tokens: int | None,
) -> AsyncIterator[str]:
    """Yield SSE events for one streaming provider turn.

    Bridges normalized provider stream events into the relay's SSE wire format
    and converts stream failures into SSE error events.
    """
    started_at = time.perf_counter()
    yield _encode_sse_event("start", {"status": "working"})

    try:
        async for event in get_provider().generate_stream(provider_request):
            if event.type == "delta" and event.delta:
                yield _encode_sse_event("delta", {"delta": event.delta})

View source record →