push

Author: hassiebp

langfuse/api/__init__.py

@@ -78,6 +78,7 @@
         Comment,
         CommentObjectType,
         ConfigCategory,
+        CorrectionScore,
         CreateScoreValue,
         Dataset,
         DatasetItem,
@@ -112,6 +113,7 @@
         ScoreV1_Numeric,
         Score_Boolean,
         Score_Categorical,
+        Score_Correction,
         Score_Numeric,
         Session,
         SessionWithTraces,
@@ -279,9 +281,11 @@
         GetScoresResponseData,
         GetScoresResponseDataBoolean,
         GetScoresResponseDataCategorical,
+        GetScoresResponseDataCorrection,
         GetScoresResponseDataNumeric,
         GetScoresResponseData_Boolean,
         GetScoresResponseData_Categorical,
+        GetScoresResponseData_Correction,
         GetScoresResponseData_Numeric,
         GetScoresResponseTraceData,
     )
@@ -323,6 +327,7 @@
     "Comment": ".commons",
     "CommentObjectType": ".commons",
     "ConfigCategory": ".commons",
+    "CorrectionScore": ".commons",
     "CreateAnnotationQueueAssignmentResponse": ".annotation_queues",
     "CreateAnnotationQueueItemRequest": ".annotation_queues",
     "CreateAnnotationQueueRequest": ".annotation_queues",
@@ -372,9 +377,11 @@
     "GetScoresResponseData": ".score_v2",
     "GetScoresResponseDataBoolean": ".score_v2",
     "GetScoresResponseDataCategorical": ".score_v2",
+    "GetScoresResponseDataCorrection": ".score_v2",
     "GetScoresResponseDataNumeric": ".score_v2",
     "GetScoresResponseData_Boolean": ".score_v2",
     "GetScoresResponseData_Categorical": ".score_v2",
+    "GetScoresResponseData_Correction": ".score_v2",
     "GetScoresResponseData_Numeric": ".score_v2",
     "GetScoresResponseTraceData": ".score_v2",
     "HealthResponse": ".health",
@@ -488,6 +495,7 @@
     "ScoreV1_Numeric": ".commons",
     "Score_Boolean": ".commons",
     "Score_Categorical": ".commons",
+    "Score_Correction": ".commons",
     "Score_Numeric": ".commons",
     "SdkLogBody": ".ingestion",
     "SdkLogEvent": ".ingestion",

langfuse/api/commons/__init__.py

@@ -16,6 +16,7 @@
         Comment,
         CommentObjectType,
         ConfigCategory,
+        CorrectionScore,
         CreateScoreValue,
         Dataset,
         DatasetItem,
@@ -47,6 +48,7 @@
         ScoreV1_Numeric,
         Score_Boolean,
         Score_Categorical,
+        Score_Correction,
         Score_Numeric,
         Session,
         SessionWithTraces,
@@ -73,6 +75,7 @@
     "Comment": ".types",
     "CommentObjectType": ".types",
     "ConfigCategory": ".types",
+    "CorrectionScore": ".types",
     "CreateScoreValue": ".types",
     "Dataset": ".types",
     "DatasetItem": ".types",
@@ -107,6 +110,7 @@
     "ScoreV1_Numeric": ".types",
     "Score_Boolean": ".types",
     "Score_Categorical": ".types",
+    "Score_Correction": ".types",
     "Score_Numeric": ".types",
     "Session": ".types",
     "SessionWithTraces": ".types",
@@ -156,6 +160,7 @@ def __dir__():
     "Comment",
     "CommentObjectType",
     "ConfigCategory",
+    "CorrectionScore",
     "CreateScoreValue",
     "Dataset",
     "DatasetItem",
@@ -190,6 +195,7 @@ def __dir__():
     "ScoreV1_Numeric",
     "Score_Boolean",
     "Score_Categorical",
+    "Score_Correction",
     "Score_Numeric",
     "Session",
     "SessionWithTraces",

langfuse/api/commons/types/__init__.py

@@ -15,6 +15,7 @@
     from .comment import Comment
     from .comment_object_type import CommentObjectType
     from .config_category import ConfigCategory
+    from .correction_score import CorrectionScore
     from .create_score_value import CreateScoreValue
     from .dataset import Dataset
     from .dataset_item import DatasetItem
@@ -35,7 +36,13 @@
     from .pricing_tier_condition import PricingTierCondition
     from .pricing_tier_input import PricingTierInput
     from .pricing_tier_operator import PricingTierOperator
-    from .score import Score, Score_Boolean, Score_Categorical, Score_Numeric
+    from .score import (
+        Score,
+        Score_Boolean,
+        Score_Categorical,
+        Score_Correction,
+        Score_Numeric,
+    )
     from .score_config import ScoreConfig
     from .score_config_data_type import ScoreConfigDataType
     from .score_data_type import ScoreDataType
@@ -57,6 +64,7 @@
     "Comment": ".comment",
     "CommentObjectType": ".comment_object_type",
     "ConfigCategory": ".config_category",
+    "CorrectionScore": ".correction_score",
     "CreateScoreValue": ".create_score_value",
     "Dataset": ".dataset",
     "DatasetItem": ".dataset_item",
@@ -88,6 +96,7 @@
     "ScoreV1_Numeric": ".score_v1",
     "Score_Boolean": ".score",
     "Score_Categorical": ".score",
+    "Score_Correction": ".score",
     "Score_Numeric": ".score",
     "Session": ".session",
     "SessionWithTraces": ".session_with_traces",
@@ -135,6 +144,7 @@ def __dir__():
     "Comment",
     "CommentObjectType",
     "ConfigCategory",
+    "CorrectionScore",
     "CreateScoreValue",
     "Dataset",
     "DatasetItem",
@@ -166,6 +176,7 @@ def __dir__():
     "ScoreV1_Numeric",
     "Score_Boolean",
     "Score_Categorical",
+    "Score_Correction",
     "Score_Numeric",
     "Session",
     "SessionWithTraces",

langfuse/api/commons/types/correction_score.py

@@ -1,24 +1,43 @@
 # This file was auto-generated by Fern from our API Definition.
 
+<<<<<<< HEAD
 import datetime as dt
 import typing
 
 from ....core.datetime_utils import serialize_datetime
 from ....core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
+=======
+import typing
+
+import pydantic
+import typing_extensions
+from ...core.serialization import FieldMetadata
+>>>>>>> 4bf1ac17 (push)
 from .base_score import BaseScore
 
 
 class CorrectionScore(BaseScore):
+<<<<<<< HEAD
     value: float = pydantic_v1.Field()
+=======
+    value: float = pydantic.Field()
+>>>>>>> 4bf1ac17 (push)
     """
     The numeric value of the score. Always 0 for correction scores.
     """
 
+<<<<<<< HEAD
     string_value: str = pydantic_v1.Field(alias="stringValue")
+=======
+    string_value: typing_extensions.Annotated[
+        str, FieldMetadata(alias="stringValue")
+    ] = pydantic.Field()
+>>>>>>> 4bf1ac17 (push)
     """
     The string representation of the correction content
     """
 
+<<<<<<< HEAD
     def json(self, **kwargs: typing.Any) -> str:
         kwargs_with_defaults: typing.Any = {
             "by_alias": True,
@@ -51,3 +70,8 @@ class Config:
         populate_by_name = True
         extra = pydantic_v1.Extra.allow
         json_encoders = {dt.datetime: serialize_datetime}
+=======
+    model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
+        extra="allow", frozen=True
+    )
+>>>>>>> 4bf1ac17 (push)

langfuse/api/commons/types/score.py

@@ -149,7 +149,53 @@ class Score_Boolean(UniversalBaseModel):
     )
 
 
+class Score_Correction(UniversalBaseModel):
+    data_type: typing_extensions.Annotated[
+        typing.Literal["CORRECTION"], FieldMetadata(alias="dataType")
+    ] = "CORRECTION"
+    value: float
+    string_value: typing_extensions.Annotated[str, FieldMetadata(alias="stringValue")]
+    id: str
+    trace_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="traceId")
+    ] = None
+    session_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="sessionId")
+    ] = None
+    observation_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="observationId")
+    ] = None
+    dataset_run_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="datasetRunId")
+    ] = None
+    name: str
+    source: ScoreSource
+    timestamp: dt.datetime
+    created_at: typing_extensions.Annotated[
+        dt.datetime, FieldMetadata(alias="createdAt")
+    ]
+    updated_at: typing_extensions.Annotated[
+        dt.datetime, FieldMetadata(alias="updatedAt")
+    ]
+    author_user_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="authorUserId")
+    ] = None
+    comment: typing.Optional[str] = None
+    metadata: typing.Any
+    config_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="configId")
+    ] = None
+    queue_id: typing_extensions.Annotated[
+        typing.Optional[str], FieldMetadata(alias="queueId")
+    ] = None
+    environment: str
+
+    model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
+        extra="allow", frozen=True
+    )
+
+
 Score = typing_extensions.Annotated[
-    typing.Union[Score_Numeric, Score_Categorical, Score_Boolean],
+    typing.Union[Score_Numeric, Score_Categorical, Score_Boolean, Score_Correction],
     pydantic.Field(discriminator="data_type"),
 ]

langfuse/api/dataset_items/client.py

@@ -1,5 +1,6 @@
 # This file was auto-generated by Fern from our API Definition.
 
+import datetime as dt
 import typing
 
 from ..commons.types.dataset_item import DatasetItem
@@ -143,12 +144,14 @@ def list(
         dataset_name: typing.Optional[str] = None,
         source_trace_id: typing.Optional[str] = None,
         source_observation_id: typing.Optional[str] = None,
+        version: typing.Optional[dt.datetime] = None,
         page: typing.Optional[int] = None,
         limit: typing.Optional[int] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> PaginatedDatasetItems:
         """
-        Get dataset items
+        Get dataset items. Optionally specify a version to get the items as they existed at that point in time.
+        Note: If version parameter is provided, datasetName must also be provided.
 
         Parameters
         ----------
@@ -158,6 +161,11 @@ def list(
 
         source_observation_id : typing.Optional[str]
 
+        version : typing.Optional[dt.datetime]
+            ISO 8601 timestamp (RFC 3339, Section 5.6) in UTC (e.g., "2026-01-21T14:35:42Z").
+            If provided, returns state of dataset at this timestamp.
+            If not provided, returns the latest version. Requires datasetName to be specified.
+
         page : typing.Optional[int]
             page number, starts at 1
 
@@ -189,6 +197,7 @@ def list(
             dataset_name=dataset_name,
             source_trace_id=source_trace_id,
             source_observation_id=source_observation_id,
+            version=version,
             page=page,
             limit=limit,
             request_options=request_options,
@@ -377,12 +386,14 @@ async def list(
         dataset_name: typing.Optional[str] = None,
         source_trace_id: typing.Optional[str] = None,
         source_observation_id: typing.Optional[str] = None,
+        version: typing.Optional[dt.datetime] = None,
         page: typing.Optional[int] = None,
         limit: typing.Optional[int] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> PaginatedDatasetItems:
         """
-        Get dataset items
+        Get dataset items. Optionally specify a version to get the items as they existed at that point in time.
+        Note: If version parameter is provided, datasetName must also be provided.
 
         Parameters
         ----------
@@ -392,6 +403,11 @@ async def list(
 
         source_observation_id : typing.Optional[str]
 
+        version : typing.Optional[dt.datetime]
+            ISO 8601 timestamp (RFC 3339, Section 5.6) in UTC (e.g., "2026-01-21T14:35:42Z").
+            If provided, returns state of dataset at this timestamp.
+            If not provided, returns the latest version. Requires datasetName to be specified.
+
         page : typing.Optional[int]
             page number, starts at 1
 
@@ -431,6 +447,7 @@ async def main() -> None:
             dataset_name=dataset_name,
             source_trace_id=source_trace_id,
             source_observation_id=source_observation_id,
+            version=version,
             page=page,
             limit=limit,
             request_options=request_options,