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
130 changes: 43 additions & 87 deletions langfuse/api/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
scim,
score_configs,
scores,
scores_v3,
sessions,
trace,
unstable,
Expand Down Expand Up @@ -284,37 +283,22 @@
UpdateScoreConfigRequest,
)
from .scores import (
GetScoresResponse,
GetScoresResponseData,
GetScoresResponseDataBoolean,
GetScoresResponseDataCategorical,
GetScoresResponseDataCorrection,
GetScoresResponseDataNumeric,
GetScoresResponseDataText,
GetScoresResponseData_Boolean,
GetScoresResponseData_Categorical,
GetScoresResponseData_Correction,
GetScoresResponseData_Numeric,
GetScoresResponseData_Text,
GetScoresResponseTraceData,
)
from .scores_v3 import (
BaseScoreV3,
BooleanScoreV3,
CategoricalScoreV3,
CorrectionScoreV3,
GetScoresV3Meta,
GetScoresV3Response,
GetScoresMeta,
GetScoresResponse,
NumericScoreV3,
ScoreSubjectExperimentV3,
ScoreSubjectObservationV3,
ScoreSubjectSessionV3,
ScoreSubjectTraceV3,
ScoreSubjectV3,
ScoreSubjectV3_Experiment,
ScoreSubjectV3_Observation,
ScoreSubjectV3_Session,
ScoreSubjectV3_Trace,
ScoreSubject,
ScoreSubjectExperiment,
ScoreSubjectObservation,
ScoreSubjectSession,
ScoreSubjectTrace,
ScoreSubject_Experiment,
ScoreSubject_Observation,
ScoreSubject_Session,
ScoreSubject_Trace,
ScoreV3,
ScoreV3_Boolean,
ScoreV3_Categorical,
Expand Down Expand Up @@ -342,7 +326,7 @@
"BasePrompt": ".prompts",
"BaseScore": ".commons",
"BaseScoreV1": ".commons",
"BaseScoreV3": ".scores_v3",
"BaseScoreV3": ".scores",
"BlobStorageExportFieldGroup": ".blob_storage_integrations",
"BlobStorageExportFrequency": ".blob_storage_integrations",
"BlobStorageExportMode": ".blob_storage_integrations",
Expand All @@ -356,11 +340,11 @@
"BlobStorageSyncStatus": ".blob_storage_integrations",
"BooleanScore": ".commons",
"BooleanScoreV1": ".commons",
"BooleanScoreV3": ".scores_v3",
"BooleanScoreV3": ".scores",
"BulkConfig": ".scim",
"CategoricalScore": ".commons",
"CategoricalScoreV1": ".commons",
"CategoricalScoreV3": ".scores_v3",
"CategoricalScoreV3": ".scores",
"ChatMessage": ".prompts",
"ChatMessageType": ".prompts",
"ChatMessageWithPlaceholders": ".prompts",
Expand All @@ -369,7 +353,7 @@
"CommentObjectType": ".commons",
"ConfigCategory": ".commons",
"CorrectionScore": ".commons",
"CorrectionScoreV3": ".scores_v3",
"CorrectionScoreV3": ".scores",
"CreateAnnotationQueueAssignmentResponse": ".annotation_queues",
"CreateAnnotationQueueItemRequest": ".annotation_queues",
"CreateAnnotationQueueRequest": ".annotation_queues",
Expand Down Expand Up @@ -414,21 +398,8 @@
"GetMediaResponse": ".media",
"GetMediaUploadUrlRequest": ".media",
"GetMediaUploadUrlResponse": ".media",
"GetScoresMeta": ".scores",
"GetScoresResponse": ".scores",
"GetScoresResponseData": ".scores",
"GetScoresResponseDataBoolean": ".scores",
"GetScoresResponseDataCategorical": ".scores",
"GetScoresResponseDataCorrection": ".scores",
"GetScoresResponseDataNumeric": ".scores",
"GetScoresResponseDataText": ".scores",
"GetScoresResponseData_Boolean": ".scores",
"GetScoresResponseData_Categorical": ".scores",
"GetScoresResponseData_Correction": ".scores",
"GetScoresResponseData_Numeric": ".scores",
"GetScoresResponseData_Text": ".scores",
"GetScoresResponseTraceData": ".scores",
"GetScoresV3Meta": ".scores_v3",
"GetScoresV3Response": ".scores_v3",
"HealthResponse": ".health",
"IngestionError": ".ingestion",
"IngestionEvent": ".ingestion",
Expand Down Expand Up @@ -463,7 +434,7 @@
"NotFoundError": ".commons",
"NumericScore": ".commons",
"NumericScoreV1": ".commons",
"NumericScoreV3": ".scores_v3",
"NumericScoreV3": ".scores",
"Observation": ".commons",
"ObservationBody": ".ingestion",
"ObservationLevel": ".commons",
Expand Down Expand Up @@ -533,26 +504,26 @@
"ScoreDataType": ".commons",
"ScoreEvent": ".ingestion",
"ScoreSource": ".commons",
"ScoreSubjectExperimentV3": ".scores_v3",
"ScoreSubjectObservationV3": ".scores_v3",
"ScoreSubjectSessionV3": ".scores_v3",
"ScoreSubjectTraceV3": ".scores_v3",
"ScoreSubjectV3": ".scores_v3",
"ScoreSubjectV3_Experiment": ".scores_v3",
"ScoreSubjectV3_Observation": ".scores_v3",
"ScoreSubjectV3_Session": ".scores_v3",
"ScoreSubjectV3_Trace": ".scores_v3",
"ScoreSubject": ".scores",
"ScoreSubjectExperiment": ".scores",
"ScoreSubjectObservation": ".scores",
"ScoreSubjectSession": ".scores",
"ScoreSubjectTrace": ".scores",
"ScoreSubject_Experiment": ".scores",
"ScoreSubject_Observation": ".scores",
"ScoreSubject_Session": ".scores",
"ScoreSubject_Trace": ".scores",
"ScoreV1": ".commons",
"ScoreV1_Boolean": ".commons",
"ScoreV1_Categorical": ".commons",
"ScoreV1_Numeric": ".commons",
"ScoreV1_Text": ".commons",
"ScoreV3": ".scores_v3",
"ScoreV3_Boolean": ".scores_v3",
"ScoreV3_Categorical": ".scores_v3",
"ScoreV3_Correction": ".scores_v3",
"ScoreV3_Numeric": ".scores_v3",
"ScoreV3_Text": ".scores_v3",
"ScoreV3": ".scores",
"ScoreV3_Boolean": ".scores",
"ScoreV3_Categorical": ".scores",
"ScoreV3_Correction": ".scores",
"ScoreV3_Numeric": ".scores",
"ScoreV3_Text": ".scores",
"Score_Boolean": ".commons",
"Score_Categorical": ".commons",
"Score_Correction": ".commons",
Expand All @@ -568,7 +539,7 @@
"TextPrompt": ".prompts",
"TextScore": ".commons",
"TextScoreV1": ".commons",
"TextScoreV3": ".scores_v3",
"TextScoreV3": ".scores",
"Trace": ".commons",
"TraceBody": ".ingestion",
"TraceEvent": ".ingestion",
Expand Down Expand Up @@ -611,7 +582,6 @@
"scim": ".scim",
"score_configs": ".score_configs",
"scores": ".scores",
"scores_v3": ".scores_v3",
"sessions": ".sessions",
"trace": ".trace",
"unstable": ".unstable",
Expand Down Expand Up @@ -735,21 +705,8 @@ def __dir__():
"GetMediaResponse",
"GetMediaUploadUrlRequest",
"GetMediaUploadUrlResponse",
"GetScoresMeta",
"GetScoresResponse",
"GetScoresResponseData",
"GetScoresResponseDataBoolean",
"GetScoresResponseDataCategorical",
"GetScoresResponseDataCorrection",
"GetScoresResponseDataNumeric",
"GetScoresResponseDataText",
"GetScoresResponseData_Boolean",
"GetScoresResponseData_Categorical",
"GetScoresResponseData_Correction",
"GetScoresResponseData_Numeric",
"GetScoresResponseData_Text",
"GetScoresResponseTraceData",
"GetScoresV3Meta",
"GetScoresV3Response",
"HealthResponse",
"IngestionError",
"IngestionEvent",
Expand Down Expand Up @@ -854,15 +811,15 @@ def __dir__():
"ScoreDataType",
"ScoreEvent",
"ScoreSource",
"ScoreSubjectExperimentV3",
"ScoreSubjectObservationV3",
"ScoreSubjectSessionV3",
"ScoreSubjectTraceV3",
"ScoreSubjectV3",
"ScoreSubjectV3_Experiment",
"ScoreSubjectV3_Observation",
"ScoreSubjectV3_Session",
"ScoreSubjectV3_Trace",
"ScoreSubject",
"ScoreSubjectExperiment",
"ScoreSubjectObservation",
"ScoreSubjectSession",
"ScoreSubjectTrace",
"ScoreSubject_Experiment",
"ScoreSubject_Observation",
"ScoreSubject_Session",
"ScoreSubject_Trace",
"ScoreV1",
"ScoreV1_Boolean",
"ScoreV1_Categorical",
Expand Down Expand Up @@ -932,7 +889,6 @@ def __dir__():
"scim",
"score_configs",
"scores",
"scores_v3",
"sessions",
"trace",
"unstable",
Expand Down
19 changes: 0 additions & 19 deletions langfuse/api/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@
from .scim.client import AsyncScimClient, ScimClient
from .score_configs.client import AsyncScoreConfigsClient, ScoreConfigsClient
from .scores.client import AsyncScoresClient, ScoresClient
from .scores_v3.client import AsyncScoresV3Client, ScoresV3Client
from .sessions.client import AsyncSessionsClient, SessionsClient
from .trace.client import AsyncTraceClient, TraceClient
from .unstable.client import AsyncUnstableClient, UnstableClient
Expand Down Expand Up @@ -146,7 +145,6 @@ def __init__(
self._prompts: typing.Optional[PromptsClient] = None
self._scim: typing.Optional[ScimClient] = None
self._score_configs: typing.Optional[ScoreConfigsClient] = None
self._scores_v3: typing.Optional[ScoresV3Client] = None
self._scores: typing.Optional[ScoresClient] = None
self._sessions: typing.Optional[SessionsClient] = None
self._trace: typing.Optional[TraceClient] = None
Expand Down Expand Up @@ -338,14 +336,6 @@ def score_configs(self):
)
return self._score_configs

@property
def scores_v3(self):
if self._scores_v3 is None:
from .scores_v3.client import ScoresV3Client # noqa: E402

self._scores_v3 = ScoresV3Client(client_wrapper=self._client_wrapper)
return self._scores_v3

@property
def scores(self):
if self._scores is None:
Expand Down Expand Up @@ -480,7 +470,6 @@ def __init__(
self._prompts: typing.Optional[AsyncPromptsClient] = None
self._scim: typing.Optional[AsyncScimClient] = None
self._score_configs: typing.Optional[AsyncScoreConfigsClient] = None
self._scores_v3: typing.Optional[AsyncScoresV3Client] = None
self._scores: typing.Optional[AsyncScoresClient] = None
self._sessions: typing.Optional[AsyncSessionsClient] = None
self._trace: typing.Optional[AsyncTraceClient] = None
Expand Down Expand Up @@ -676,14 +665,6 @@ def score_configs(self):
)
return self._score_configs

@property
def scores_v3(self):
if self._scores_v3 is None:
from .scores_v3.client import AsyncScoresV3Client # noqa: E402

self._scores_v3 = AsyncScoresV3Client(client_wrapper=self._client_wrapper)
return self._scores_v3

@property
def scores(self):
if self._scores is None:
Expand Down
45 changes: 44 additions & 1 deletion langfuse/api/legacy/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,20 +6,49 @@
from importlib import import_module

if typing.TYPE_CHECKING:
from . import metrics_v1, observations_v1, score_v1
from . import metrics_v1, observations_v1, score_v1, scores_v2
from .metrics_v1 import MetricsResponse
from .observations_v1 import Observations, ObservationsViews
from .score_v1 import CreateScoreRequest, CreateScoreResponse, CreateScoreSource
from .scores_v2 import (
GetScoresResponse,
GetScoresResponseData,
GetScoresResponseDataBoolean,
GetScoresResponseDataCategorical,
GetScoresResponseDataCorrection,
GetScoresResponseDataNumeric,
GetScoresResponseDataText,
GetScoresResponseData_Boolean,
GetScoresResponseData_Categorical,
GetScoresResponseData_Correction,
GetScoresResponseData_Numeric,
GetScoresResponseData_Text,
GetScoresResponseTraceData,
)
_dynamic_imports: typing.Dict[str, str] = {
"CreateScoreRequest": ".score_v1",
"CreateScoreResponse": ".score_v1",
"CreateScoreSource": ".score_v1",
"GetScoresResponse": ".scores_v2",
"GetScoresResponseData": ".scores_v2",
"GetScoresResponseDataBoolean": ".scores_v2",
"GetScoresResponseDataCategorical": ".scores_v2",
"GetScoresResponseDataCorrection": ".scores_v2",
"GetScoresResponseDataNumeric": ".scores_v2",
"GetScoresResponseDataText": ".scores_v2",
"GetScoresResponseData_Boolean": ".scores_v2",
"GetScoresResponseData_Categorical": ".scores_v2",
"GetScoresResponseData_Correction": ".scores_v2",
"GetScoresResponseData_Numeric": ".scores_v2",
"GetScoresResponseData_Text": ".scores_v2",
"GetScoresResponseTraceData": ".scores_v2",
"MetricsResponse": ".metrics_v1",
"Observations": ".observations_v1",
"ObservationsViews": ".observations_v1",
"metrics_v1": ".metrics_v1",
"observations_v1": ".observations_v1",
"score_v1": ".score_v1",
"scores_v2": ".scores_v2",
}


Expand Down Expand Up @@ -54,10 +83,24 @@ def __dir__():
"CreateScoreRequest",
"CreateScoreResponse",
"CreateScoreSource",
"GetScoresResponse",
"GetScoresResponseData",
"GetScoresResponseDataBoolean",
"GetScoresResponseDataCategorical",
"GetScoresResponseDataCorrection",
"GetScoresResponseDataNumeric",
"GetScoresResponseDataText",
"GetScoresResponseData_Boolean",
"GetScoresResponseData_Categorical",
"GetScoresResponseData_Correction",
"GetScoresResponseData_Numeric",
"GetScoresResponseData_Text",
"GetScoresResponseTraceData",
"MetricsResponse",
"Observations",
"ObservationsViews",
"metrics_v1",
"observations_v1",
"score_v1",
"scores_v2",
]
Loading
Loading