Errors

export class RpcError extends Error {
  constructor(
  static withReason(code: number, reason: string, message: string): RpcError
  toJSON(): JsonRpcError
}

class RPCError(ExecutorError):
    """A JSON-RPC error. A handler that raises it keeps its code on the wire."""
    def __init__(self, code: int, message: str, data: dict[str, Any] | None = None) -> None: ...
    @classmethod
    def with_reason(cls, code: int, reason: str, message: str) -> RPCError: ...
    @property
    def retryable(self) -> bool | None: ...
    def to_wire(self) -> dict[str, Any]: ...

type RPCError struct {
	Code    int
	Message string
	Data    *JSONRPCErrorData
}

export class NotConnectedError extends Error {
  constructor(message = 'executor channel is not connected')
}

export class ClientStoppedError extends Error {
  constructor()
}

export class RequestTimeoutError extends Error {
  constructor(method: string)
}

class NotConnectedError(ExecutorError):
    """The channel is not connected (yet, or any more)."""
    def __init__(self, message: str = "executor channel is not connected") -> None: ...

class ClientStoppedError(ExecutorError):
    """The client was stopped, or closed with a terminal close code."""
    def __init__(self, message: str = "client stopped") -> None: ...

var (
	// ErrNotConnected is returned when a call is attempted before the channel opens.
	ErrNotConnected = errors.New("bmaexecutor: executor channel is not connected")
	// ErrClientStopped is returned after Stop or a terminal close code.
	ErrClientStopped = errors.New("bmaexecutor: client stopped")
	// ErrReplaced is Err after the harness closed with 4004: a newer
	// connection for this executor is authoritative and this one must stop.
	ErrReplaced = errors.New("bmaexecutor: executor connection was replaced (4004)")
	// ErrReconnectExhausted is Err after a positive MaxReconnectAttempts
	// failed; it wraps the last failure.
	ErrReconnectExhausted = errors.New("bmaexecutor: executor reconnect attempts exhausted")
	// ErrCredentialRejected is wrapped by the token request error when the
	// token endpoint answers 401 or 403 (an invalid or revoked environment
	// key or machine token). A reconnect does not retry it: the client ends
	// with it as Err. A TokenSource may wrap it for the same effect.
	ErrCredentialRejected = errors.New("bmaexecutor: executor credential rejected")
	// ErrRegistrationRefused is Err after the platform refused the
	// executor's registration maxRefusedRegistrations times in a row: the
	// close 4002 "runtime registration refused" right after
	// executor.register, or an executor.register error for the executor's
	// capabilities. It is a configuration error (a machine-scoped executor
	// must declare the process or agent capability) that reconnecting
	// cannot fix. It wraps the last refusal.
	ErrRegistrationRefused = errors.New("bmaexecutor: executor registration refused")
)

export class SessionEndedError extends Error {
  constructor()
}

export class ToolOutcomeUnknownError extends Error {
  constructor()
}

export class AssignRejectedError extends Error {
  constructor()
}

class SessionEndedError(ExecutorError):
    """A request on a session that has ended."""
    def __init__(self) -> None: ...

class ToolOutcomeUnknownError(ExecutorError):
    """The executor was lost (lease expiry, executor.close, session ended, or a"""
    def __init__(self) -> None: ...

class AssignRejectedError(ExecutorError):
    """session.assign answered accepted=false."""
    def __init__(self) -> None: ...

var (
	// ErrSessionEnded is returned for requests on a session that has ended.
	ErrSessionEnded = errors.New("bmaexecutor: session ended")
	// ErrToolOutcomeUnknown means the executor was lost (lease expiry,
	// executor.close, session ended, or a restarted executor that no longer
	// reports the session) before a tool.result arrived. The tool may or may
	// not have run; the caller decides whether a retry is safe.
	ErrToolOutcomeUnknown = errors.New("bmaexecutor: tool outcome unknown: executor lost before tool.result")
	// ErrAssignRejected is returned when session.assign answers accepted=false.
	ErrAssignRejected = errors.New("bmaexecutor: executor rejected session.assign")
)

export function isTerminalCloseCode(code: number): boolean

# Not in the Python SDK 1.3.0.

func CloseCode(err error) int