mirror of
https://github.com/wassname/openrouter-python-sdk-retry-errors.git
synced 2026-08-02 12:50:48 +08:00
reset to v0.1.0
This commit is contained in:
@@ -3,10 +3,10 @@
|
||||
import importlib.metadata
|
||||
|
||||
__title__: str = "openrouter"
|
||||
__version__: str = "0.6.2"
|
||||
__version__: str = "0.1.0"
|
||||
__openapi_doc_version__: str = "1.0.0"
|
||||
__gen_version__: str = "2.695.0"
|
||||
__user_agent__: str = "speakeasy-sdk/python 0.6.2 2.695.0 1.0.0 openrouter"
|
||||
__gen_version__: str = "2.701.8"
|
||||
__user_agent__: str = "speakeasy-sdk/python 0.1.0 2.701.8 1.0.0 openrouter"
|
||||
|
||||
try:
|
||||
if __package__ is not None:
|
||||
|
||||
@@ -132,7 +132,7 @@ class Chat(BaseSDK):
|
||||
timeout_ms: Optional[int] = None,
|
||||
accept_header_override: Optional[CompleteAcceptEnum] = None,
|
||||
http_headers: Optional[Mapping[str, str]] = None,
|
||||
) -> eventstreaming.EventStream[models.ChatCompletionChunkWrapper]: ...
|
||||
) -> eventstreaming.EventStream[models.ChatCompletionChunk]: ...
|
||||
|
||||
def complete(
|
||||
self,
|
||||
@@ -334,7 +334,7 @@ class Chat(BaseSDK):
|
||||
http_res,
|
||||
lambda raw: utils.unmarshal_json(
|
||||
raw, models.ChatCompletionChunkWrapper
|
||||
),
|
||||
).data,
|
||||
sentinel="[DONE]",
|
||||
client_ref=self,
|
||||
)
|
||||
@@ -482,7 +482,7 @@ class Chat(BaseSDK):
|
||||
timeout_ms: Optional[int] = None,
|
||||
accept_header_override: Optional[CompleteAcceptEnum] = None,
|
||||
http_headers: Optional[Mapping[str, str]] = None,
|
||||
) -> eventstreaming.EventStreamAsync[models.ChatCompletionChunkWrapper]: ...
|
||||
) -> eventstreaming.EventStreamAsync[models.ChatCompletionChunk]: ...
|
||||
|
||||
async def complete_async(
|
||||
self,
|
||||
@@ -684,7 +684,7 @@ class Chat(BaseSDK):
|
||||
http_res,
|
||||
lambda raw: utils.unmarshal_json(
|
||||
raw, models.ChatCompletionChunkWrapper
|
||||
),
|
||||
).data,
|
||||
sentinel="[DONE]",
|
||||
client_ref=self,
|
||||
)
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT."""
|
||||
|
||||
from __future__ import annotations
|
||||
from dataclasses import dataclass, field
|
||||
import httpx
|
||||
from openrouter.errors import OpenRouterError
|
||||
from openrouter.models import chatcompletionerror as models_chatcompletionerror
|
||||
@@ -13,10 +14,11 @@ class ChatCompletionErrorData(BaseModel):
|
||||
r"""Error object structure"""
|
||||
|
||||
|
||||
@dataclass(frozen=True)
|
||||
class ChatCompletionError(OpenRouterError):
|
||||
r"""Chat completion error response"""
|
||||
|
||||
data: ChatCompletionErrorData
|
||||
data: ChatCompletionErrorData = field(hash=False)
|
||||
|
||||
def __init__(
|
||||
self,
|
||||
@@ -27,4 +29,4 @@ class ChatCompletionError(OpenRouterError):
|
||||
fallback = body or raw_response.text
|
||||
message = str(data.error.message) or fallback
|
||||
super().__init__(message, raw_response, body)
|
||||
self.data = data
|
||||
object.__setattr__(self, "data", data)
|
||||
|
||||
@@ -1,12 +1,16 @@
|
||||
"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT."""
|
||||
|
||||
from dataclasses import dataclass
|
||||
|
||||
|
||||
@dataclass(frozen=True)
|
||||
class NoResponseError(Exception):
|
||||
"""Error raised when no HTTP response is received from the server."""
|
||||
|
||||
message: str
|
||||
|
||||
def __init__(self, message: str = "No response received"):
|
||||
self.message = message
|
||||
object.__setattr__(self, "message", message)
|
||||
super().__init__(message)
|
||||
|
||||
def __str__(self):
|
||||
|
||||
@@ -2,12 +2,14 @@
|
||||
|
||||
import httpx
|
||||
from typing import Optional
|
||||
from dataclasses import dataclass
|
||||
|
||||
from openrouter.errors import OpenRouterError
|
||||
|
||||
MAX_MESSAGE_LEN = 10_000
|
||||
|
||||
|
||||
@dataclass(frozen=True)
|
||||
class OpenRouterDefaultError(OpenRouterError):
|
||||
"""The fallback error class if no more specific error class is matched."""
|
||||
|
||||
|
||||
@@ -2,25 +2,29 @@
|
||||
|
||||
import httpx
|
||||
from typing import Optional
|
||||
from dataclasses import dataclass, field
|
||||
|
||||
|
||||
@dataclass(frozen=True)
|
||||
class OpenRouterError(Exception):
|
||||
"""The base class for all HTTP error responses."""
|
||||
|
||||
message: str
|
||||
status_code: int
|
||||
body: str
|
||||
headers: httpx.Headers
|
||||
raw_response: httpx.Response
|
||||
headers: httpx.Headers = field(hash=False)
|
||||
raw_response: httpx.Response = field(hash=False)
|
||||
|
||||
def __init__(
|
||||
self, message: str, raw_response: httpx.Response, body: Optional[str] = None
|
||||
):
|
||||
self.message = message
|
||||
self.status_code = raw_response.status_code
|
||||
self.body = body if body is not None else raw_response.text
|
||||
self.headers = raw_response.headers
|
||||
self.raw_response = raw_response
|
||||
object.__setattr__(self, "message", message)
|
||||
object.__setattr__(self, "status_code", raw_response.status_code)
|
||||
object.__setattr__(
|
||||
self, "body", body if body is not None else raw_response.text
|
||||
)
|
||||
object.__setattr__(self, "headers", raw_response.headers)
|
||||
object.__setattr__(self, "raw_response", raw_response)
|
||||
|
||||
def __str__(self):
|
||||
return self.message
|
||||
|
||||
@@ -2,10 +2,12 @@
|
||||
|
||||
import httpx
|
||||
from typing import Optional
|
||||
from dataclasses import dataclass
|
||||
|
||||
from openrouter.errors import OpenRouterError
|
||||
|
||||
|
||||
@dataclass(frozen=True)
|
||||
class ResponseValidationError(OpenRouterError):
|
||||
"""Error raised when there is a type mismatch between the response data and the expected Pydantic model."""
|
||||
|
||||
|
||||
@@ -2,10 +2,7 @@
|
||||
|
||||
from __future__ import annotations
|
||||
from .chatcompletion import ChatCompletion, ChatCompletionTypedDict
|
||||
from .chatcompletionchunkwrapper import (
|
||||
ChatCompletionChunkWrapper,
|
||||
ChatCompletionChunkWrapperTypedDict,
|
||||
)
|
||||
from .chatcompletionchunk import ChatCompletionChunk, ChatCompletionChunkTypedDict
|
||||
from openrouter.utils import eventstreaming
|
||||
from typing import Union
|
||||
from typing_extensions import TypeAliasType
|
||||
@@ -16,8 +13,8 @@ CreateChatCompletionResponseTypedDict = TypeAliasType(
|
||||
Union[
|
||||
ChatCompletionTypedDict,
|
||||
Union[
|
||||
eventstreaming.EventStream[ChatCompletionChunkWrapperTypedDict],
|
||||
eventstreaming.EventStreamAsync[ChatCompletionChunkWrapperTypedDict],
|
||||
eventstreaming.EventStream[ChatCompletionChunkTypedDict],
|
||||
eventstreaming.EventStreamAsync[ChatCompletionChunkTypedDict],
|
||||
],
|
||||
],
|
||||
)
|
||||
@@ -28,8 +25,8 @@ CreateChatCompletionResponse = TypeAliasType(
|
||||
Union[
|
||||
ChatCompletion,
|
||||
Union[
|
||||
eventstreaming.EventStream[ChatCompletionChunkWrapper],
|
||||
eventstreaming.EventStreamAsync[ChatCompletionChunkWrapper],
|
||||
eventstreaming.EventStream[ChatCompletionChunk],
|
||||
eventstreaming.EventStreamAsync[ChatCompletionChunk],
|
||||
],
|
||||
],
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user