Skip to content
Open
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
4 changes: 2 additions & 2 deletions langfuse/api/blob_storage_integrations/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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.
Expand Down
4 changes: 2 additions & 2 deletions langfuse/api/blob_storage_integrations/raw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -22,6 +23,7 @@ class BlobStorageSyncStatus(enum.StrEnum):
"""

IDLE = "idle"
RUNNING = "running"
QUEUED = "queued"
UP_TO_DATE = "up_to_date"
DISABLED = "disabled"
Expand All @@ -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:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Loading