Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 1 addition & 4 deletions langfuse/_client/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -1868,10 +1868,7 @@ def _create_trace_tags_via_ingestion(
return

try:
new_body = TraceBody(
id=trace_id,
tags=tags,
)
new_body = TraceBody(id=trace_id, tags=tags, user_id=None, session_id=None)

event = {
"id": self.create_trace_id(),
Expand Down
4 changes: 2 additions & 2 deletions langfuse/api/.fern/metadata.json
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
{
"cliVersion": "3.30.3",
"cliVersion": "3.88.0",
"generatorName": "fernapi/fern-python-sdk",
"generatorVersion": "4.46.2",
"generatorVersion": "4.64.1",
"generatorConfig": {
"pydantic_config": {
"enum_type": "python_enums",
Expand Down
142 changes: 142 additions & 0 deletions langfuse/api/annotation_queues/raw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
from ..core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
from ..core.http_response import AsyncHttpResponse, HttpResponse
from ..core.jsonable_encoder import jsonable_encoder
from ..core.parse_error import ParsingError
from ..core.pydantic_utilities import parse_obj_as
from ..core.request_options import RequestOptions
from .types.annotation_queue import AnnotationQueue
Expand All @@ -29,6 +30,7 @@
)
from .types.paginated_annotation_queue_items import PaginatedAnnotationQueueItems
from .types.paginated_annotation_queues import PaginatedAnnotationQueues
from pydantic import ValidationError

# this is used as the default value for optional parameters
OMIT = typing.cast(typing.Any, ...)
Expand Down Expand Up @@ -144,6 +146,13 @@ def list_queues(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -259,6 +268,13 @@ def create_queue(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -360,6 +376,13 @@ def get_queue(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -481,6 +504,13 @@ def list_queue_items(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -589,6 +619,13 @@ def get_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -709,6 +746,13 @@ def create_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -824,6 +868,13 @@ def update_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -932,6 +983,13 @@ def delete_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1043,6 +1101,13 @@ def create_queue_assignment(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1154,6 +1219,13 @@ def delete_queue_assignment(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1271,6 +1343,13 @@ async def list_queues(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1386,6 +1465,13 @@ async def create_queue(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1487,6 +1573,13 @@ async def get_queue(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1608,6 +1701,13 @@ async def list_queue_items(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1716,6 +1816,13 @@ async def get_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1836,6 +1943,13 @@ async def create_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -1951,6 +2065,13 @@ async def update_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -2059,6 +2180,13 @@ async def delete_queue_item(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -2170,6 +2298,13 @@ async def create_queue_assignment(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down Expand Up @@ -2281,6 +2416,13 @@ async def delete_queue_assignment(
headers=dict(_response.headers),
body=_response.text,
)
except ValidationError as e:
raise ParsingError(
status_code=_response.status_code,
headers=dict(_response.headers),
body=_response.json(),
cause=e,
)
raise ApiError(
status_code=_response.status_code,
headers=dict(_response.headers),
Expand Down
8 changes: 5 additions & 3 deletions langfuse/api/annotation_queues/types/annotation_queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,15 @@ class AnnotationQueue(UniversalBaseModel):
name: str
description: typing.Optional[str] = None
score_config_ids: typing_extensions.Annotated[
typing.List[str], FieldMetadata(alias="scoreConfigIds")
typing.List[str],
FieldMetadata(alias="scoreConfigIds"),
pydantic.Field(alias="scoreConfigIds"),
]
created_at: typing_extensions.Annotated[
dt.datetime, FieldMetadata(alias="createdAt")
dt.datetime, FieldMetadata(alias="createdAt"), pydantic.Field(alias="createdAt")
]
updated_at: typing_extensions.Annotated[
dt.datetime, FieldMetadata(alias="updatedAt")
dt.datetime, FieldMetadata(alias="updatedAt"), pydantic.Field(alias="updatedAt")
]

model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@


class AnnotationQueueAssignmentRequest(UniversalBaseModel):
user_id: typing_extensions.Annotated[str, FieldMetadata(alias="userId")]
user_id: typing_extensions.Annotated[
str, FieldMetadata(alias="userId"), pydantic.Field(alias="userId")
]

model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
extra="allow", frozen=True
Expand Down
22 changes: 15 additions & 7 deletions langfuse/api/annotation_queues/types/annotation_queue_item.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,20 +13,28 @@

class AnnotationQueueItem(UniversalBaseModel):
id: str
queue_id: typing_extensions.Annotated[str, FieldMetadata(alias="queueId")]
object_id: typing_extensions.Annotated[str, FieldMetadata(alias="objectId")]
queue_id: typing_extensions.Annotated[
str, FieldMetadata(alias="queueId"), pydantic.Field(alias="queueId")
]
object_id: typing_extensions.Annotated[
str, FieldMetadata(alias="objectId"), pydantic.Field(alias="objectId")
]
object_type: typing_extensions.Annotated[
AnnotationQueueObjectType, FieldMetadata(alias="objectType")
AnnotationQueueObjectType,
FieldMetadata(alias="objectType"),
pydantic.Field(alias="objectType"),
]
status: AnnotationQueueStatus
completed_at: typing_extensions.Annotated[
typing.Optional[dt.datetime], FieldMetadata(alias="completedAt")
] = None
typing.Optional[dt.datetime],
FieldMetadata(alias="completedAt"),
pydantic.Field(alias="completedAt", default=None),
]
created_at: typing_extensions.Annotated[
dt.datetime, FieldMetadata(alias="createdAt")
dt.datetime, FieldMetadata(alias="createdAt"), pydantic.Field(alias="createdAt")
]
updated_at: typing_extensions.Annotated[
dt.datetime, FieldMetadata(alias="updatedAt")
dt.datetime, FieldMetadata(alias="updatedAt"), pydantic.Field(alias="updatedAt")
]

model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
Expand Down
Loading
Loading