feat(api): update API spec from langfuse/langfuse f73fd25

langfuse/api/blob_storage_integrations/client.py

@@ -144,7 +144,7 @@ def upsert_blob_storage_integration(
             Path prefix for exported files (must end with forward slash if provided)
 
         export_start_date : typing.Optional[dt.datetime]
-            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE)
+            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE). Must not be in the future (27 h tolerance for timezone differences).
 
         compressed : typing.Optional[bool]
             Enable gzip compression for exported files (.csv.gz, .json.gz, .jsonl.gz). Defaults to true.
@@ -421,7 +421,7 @@ async def upsert_blob_storage_integration(
             Path prefix for exported files (must end with forward slash if provided)
 
         export_start_date : typing.Optional[dt.datetime]
-            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE)
+            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE). Must not be in the future (27 h tolerance for timezone differences).
 
         compressed : typing.Optional[bool]
             Enable gzip compression for exported files (.csv.gz, .json.gz, .jsonl.gz). Defaults to true.

langfuse/api/blob_storage_integrations/raw_client.py

@@ -201,7 +201,7 @@ def upsert_blob_storage_integration(
             Path prefix for exported files (must end with forward slash if provided)
 
         export_start_date : typing.Optional[dt.datetime]
-            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE)
+            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE). Must not be in the future (27 h tolerance for timezone differences).
 
         compressed : typing.Optional[bool]
             Enable gzip compression for exported files (.csv.gz, .json.gz, .jsonl.gz). Defaults to true.
@@ -696,7 +696,7 @@ async def upsert_blob_storage_integration(
             Path prefix for exported files (must end with forward slash if provided)
 
         export_start_date : typing.Optional[dt.datetime]
-            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE)
+            Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE). Must not be in the future (27 h tolerance for timezone differences).
 
         compressed : typing.Optional[bool]
             Enable gzip compression for exported files (.csv.gz, .json.gz, .jsonl.gz). Defaults to true.

langfuse/api/blob_storage_integrations/types/blob_storage_sync_status.py

@@ -12,8 +12,9 @@ class BlobStorageSyncStatus(enum.StrEnum):
     Sync status of the blob storage integration:
     - `disabled` — integration is not enabled
     - `error` — last export failed (see `lastError` for details)
-    - `idle` — enabled but has never exported yet
+    - `running` — an export job is currently being processed
     - `queued` — next export is overdue (`nextSyncAt` is in the past) and waiting to be picked up by the worker
+    - `idle` — enabled but has never exported yet and no export is queued
     - `up_to_date` — all available data has been exported; next export is scheduled for the future
 
     **ETL usage**: poll this endpoint and check for `up_to_date` status. Compare `lastSyncAt` against your
@@ -22,6 +23,7 @@ class BlobStorageSyncStatus(enum.StrEnum):
     """
 
     IDLE = "idle"
+    RUNNING = "running"
     QUEUED = "queued"
     UP_TO_DATE = "up_to_date"
     DISABLED = "disabled"
@@ -30,13 +32,16 @@ class BlobStorageSyncStatus(enum.StrEnum):
     def visit(
         self,
         idle: typing.Callable[[], T_Result],
+        running: typing.Callable[[], T_Result],
         queued: typing.Callable[[], T_Result],
         up_to_date: typing.Callable[[], T_Result],
         disabled: typing.Callable[[], T_Result],
         error: typing.Callable[[], T_Result],
     ) -> T_Result:
         if self is BlobStorageSyncStatus.IDLE:
             return idle()
+        if self is BlobStorageSyncStatus.RUNNING:
+            return running()
         if self is BlobStorageSyncStatus.QUEUED:
             return queued()
         if self is BlobStorageSyncStatus.UP_TO_DATE:

langfuse/api/blob_storage_integrations/types/create_blob_storage_integration_request.py

@@ -85,7 +85,7 @@ class CreateBlobStorageIntegrationRequest(UniversalBaseModel):
         typing.Optional[dt.datetime], FieldMetadata(alias="exportStartDate")
     ] = pydantic.Field(default=None)
     """
-    Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE)
+    Custom start date for exports (required when exportMode is FROM_CUSTOM_DATE). Must not be in the future (27 h tolerance for timezone differences).
     """
 
     compressed: typing.Optional[bool] = pydantic.Field(default=None)

langfuse/api/unstable/__init__.py

@@ -21,7 +21,7 @@
         UnauthorizedError,
         UnprocessableContentError,
     )
-    from . import commons, errors, evaluation_rules, evaluators
+    from . import commons, dashboard_widgets, errors, evaluation_rules, evaluators
     from .commons import (
         ArrayOptionsEvaluationRuleFilter,
         BooleanEvaluationRuleFilter,
@@ -73,6 +73,19 @@
         StringObjectEvaluationRuleFilter,
         StringOptionsEvaluationRuleFilter,
     )
+    from .dashboard_widgets import (
+        CreateDashboardWidgetRequest,
+        DashboardWidget,
+        DashboardWidgetChartConfig,
+        DashboardWidgetChartType,
+        DashboardWidgetDefaultSort,
+        DashboardWidgetDimension,
+        DashboardWidgetFilter,
+        DashboardWidgetMetric,
+        DashboardWidgetMetricAggregation,
+        DashboardWidgetSortOrder,
+        DashboardWidgetView,
+    )
     from .evaluation_rules import (
         CodeEvaluationRuleEvaluatorReference,
         CreateCodeEvaluationRuleRequest,
@@ -114,12 +127,23 @@
     "ConflictError": ".errors",
     "CreateCodeEvaluationRuleRequest": ".evaluation_rules",
     "CreateCodeEvaluatorRequest": ".evaluators",
+    "CreateDashboardWidgetRequest": ".dashboard_widgets",
     "CreateEvaluationRuleRequest": ".evaluation_rules",
     "CreateEvaluatorRequest": ".evaluators",
     "CreateEvaluatorRequest_Code": ".evaluators",
     "CreateEvaluatorRequest_LlmAsJudge": ".evaluators",
     "CreateLlmAsJudgeEvaluationRuleRequest": ".evaluation_rules",
     "CreateLlmAsJudgeEvaluatorRequest": ".evaluators",
+    "DashboardWidget": ".dashboard_widgets",
+    "DashboardWidgetChartConfig": ".dashboard_widgets",
+    "DashboardWidgetChartType": ".dashboard_widgets",
+    "DashboardWidgetDefaultSort": ".dashboard_widgets",
+    "DashboardWidgetDimension": ".dashboard_widgets",
+    "DashboardWidgetFilter": ".dashboard_widgets",
+    "DashboardWidgetMetric": ".dashboard_widgets",
+    "DashboardWidgetMetricAggregation": ".dashboard_widgets",
+    "DashboardWidgetSortOrder": ".dashboard_widgets",
+    "DashboardWidgetView": ".dashboard_widgets",
     "DateTimeEvaluationRuleFilter": ".commons",
     "DeleteEvaluationRuleResponse": ".evaluation_rules",
     "DeleteEvaluatorResponse": ".evaluators",
@@ -191,6 +215,7 @@
     "UnprocessableContentError": ".errors",
     "UpdateEvaluationRuleRequest": ".evaluation_rules",
     "commons": ".commons",
+    "dashboard_widgets": ".dashboard_widgets",
     "errors": ".errors",
     "evaluation_rules": ".evaluation_rules",
     "evaluators": ".evaluators",
@@ -236,12 +261,23 @@ def __dir__():
     "ConflictError",
     "CreateCodeEvaluationRuleRequest",
     "CreateCodeEvaluatorRequest",
+    "CreateDashboardWidgetRequest",
     "CreateEvaluationRuleRequest",
     "CreateEvaluatorRequest",
     "CreateEvaluatorRequest_Code",
     "CreateEvaluatorRequest_LlmAsJudge",
     "CreateLlmAsJudgeEvaluationRuleRequest",
     "CreateLlmAsJudgeEvaluatorRequest",
+    "DashboardWidget",
+    "DashboardWidgetChartConfig",
+    "DashboardWidgetChartType",
+    "DashboardWidgetDefaultSort",
+    "DashboardWidgetDimension",
+    "DashboardWidgetFilter",
+    "DashboardWidgetMetric",
+    "DashboardWidgetMetricAggregation",
+    "DashboardWidgetSortOrder",
+    "DashboardWidgetView",
     "DateTimeEvaluationRuleFilter",
     "DeleteEvaluationRuleResponse",
     "DeleteEvaluatorResponse",
@@ -313,6 +349,7 @@ def __dir__():
     "UnprocessableContentError",
     "UpdateEvaluationRuleRequest",
     "commons",
+    "dashboard_widgets",
     "errors",
     "evaluation_rules",
     "evaluators",

langfuse/api/unstable/client.py

@@ -8,6 +8,10 @@
 from .raw_client import AsyncRawUnstableClient, RawUnstableClient
 
 if typing.TYPE_CHECKING:
+    from .dashboard_widgets.client import (
+        AsyncDashboardWidgetsClient,
+        DashboardWidgetsClient,
+    )
     from .evaluation_rules.client import (
         AsyncEvaluationRulesClient,
         EvaluationRulesClient,
@@ -19,6 +23,7 @@ class UnstableClient:
     def __init__(self, *, client_wrapper: SyncClientWrapper):
         self._raw_client = RawUnstableClient(client_wrapper=client_wrapper)
         self._client_wrapper = client_wrapper
+        self._dashboard_widgets: typing.Optional[DashboardWidgetsClient] = None
         self._evaluation_rules: typing.Optional[EvaluationRulesClient] = None
         self._evaluators: typing.Optional[EvaluatorsClient] = None
 
@@ -33,6 +38,16 @@ def with_raw_response(self) -> RawUnstableClient:
         """
         return self._raw_client
 
+    @property
+    def dashboard_widgets(self):
+        if self._dashboard_widgets is None:
+            from .dashboard_widgets.client import DashboardWidgetsClient  # noqa: E402
+
+            self._dashboard_widgets = DashboardWidgetsClient(
+                client_wrapper=self._client_wrapper
+            )
+        return self._dashboard_widgets
+
     @property
     def evaluation_rules(self):
         if self._evaluation_rules is None:
@@ -56,6 +71,7 @@ class AsyncUnstableClient:
     def __init__(self, *, client_wrapper: AsyncClientWrapper):
         self._raw_client = AsyncRawUnstableClient(client_wrapper=client_wrapper)
         self._client_wrapper = client_wrapper
+        self._dashboard_widgets: typing.Optional[AsyncDashboardWidgetsClient] = None
         self._evaluation_rules: typing.Optional[AsyncEvaluationRulesClient] = None
         self._evaluators: typing.Optional[AsyncEvaluatorsClient] = None
 
@@ -70,6 +86,16 @@ def with_raw_response(self) -> AsyncRawUnstableClient:
         """
         return self._raw_client
 
+    @property
+    def dashboard_widgets(self):
+        if self._dashboard_widgets is None:
+            from .dashboard_widgets.client import AsyncDashboardWidgetsClient  # noqa: E402
+
+            self._dashboard_widgets = AsyncDashboardWidgetsClient(
+                client_wrapper=self._client_wrapper
+            )
+        return self._dashboard_widgets
+
     @property
     def evaluation_rules(self):
         if self._evaluation_rules is None:

langfuse/api/unstable/dashboard_widgets/__init__.py

@@ -0,0 +1,76 @@
+# This file was auto-generated by Fern from our API Definition.
+
+# isort: skip_file
+
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .types import (
+        CreateDashboardWidgetRequest,
+        DashboardWidget,
+        DashboardWidgetChartConfig,
+        DashboardWidgetChartType,
+        DashboardWidgetDefaultSort,
+        DashboardWidgetDimension,
+        DashboardWidgetFilter,
+        DashboardWidgetMetric,
+        DashboardWidgetMetricAggregation,
+        DashboardWidgetSortOrder,
+        DashboardWidgetView,
+    )
+_dynamic_imports: typing.Dict[str, str] = {
+    "CreateDashboardWidgetRequest": ".types",
+    "DashboardWidget": ".types",
+    "DashboardWidgetChartConfig": ".types",
+    "DashboardWidgetChartType": ".types",
+    "DashboardWidgetDefaultSort": ".types",
+    "DashboardWidgetDimension": ".types",
+    "DashboardWidgetFilter": ".types",
+    "DashboardWidgetMetric": ".types",
+    "DashboardWidgetMetricAggregation": ".types",
+    "DashboardWidgetSortOrder": ".types",
+    "DashboardWidgetView": ".types",
+}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(
+            f"No {attr_name} found in _dynamic_imports for module name -> {__name__}"
+        )
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(
+            f"Failed to import {attr_name} from {module_name}: {e}"
+        ) from e
+    except AttributeError as e:
+        raise AttributeError(
+            f"Failed to get {attr_name} from {module_name}: {e}"
+        ) from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = [
+    "CreateDashboardWidgetRequest",
+    "DashboardWidget",
+    "DashboardWidgetChartConfig",
+    "DashboardWidgetChartType",
+    "DashboardWidgetDefaultSort",
+    "DashboardWidgetDimension",
+    "DashboardWidgetFilter",
+    "DashboardWidgetMetric",
+    "DashboardWidgetMetricAggregation",
+    "DashboardWidgetSortOrder",
+    "DashboardWidgetView",
+]