Function _stream_error

python/src/cmdop/streaming.py:36–41

Raise the typed PIN exception for a PIN-gate verdict; otherwise the generic :class:`AgentStreamError` (the ask stream's error-frame contract).

(code: str, message: str)

def _stream_error(code: str, message: str) -> CmdopError:
    """Raise the typed PIN exception for a PIN-gate verdict; otherwise the
    generic :class:`AgentStreamError` (the ask stream's error-frame contract)."""
    if code in _TYPED_STREAM_ERROR_CODES:
        return map_core_error(code, message)
    return AgentStreamError(code or "internal", message or "")

if TYPE_CHECKING:
    from collections.abc import AsyncIterator