diff --git a/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type.py b/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type.py index 52998e5e4..21bb6440f 100644 --- a/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type.py +++ b/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type.py @@ -8,15 +8,21 @@ class BlobStorageIntegrationFileType(enum.StrEnum): + """ + File format for exported data. `PARQUET` is a columnar binary format encoded and compressed by the storage engine; gzip compression does not apply to it. Note that the model-price columns (`input_price`, `output_price`, `total_price`) are not included in Parquet observation exports. + """ + JSON = "JSON" CSV = "CSV" JSONL = "JSONL" + PARQUET = "PARQUET" def visit( self, json: typing.Callable[[], T_Result], csv: typing.Callable[[], T_Result], jsonl: typing.Callable[[], T_Result], + parquet: typing.Callable[[], T_Result], ) -> T_Result: if self is BlobStorageIntegrationFileType.JSON: return json() @@ -24,3 +30,5 @@ def visit( return csv() if self is BlobStorageIntegrationFileType.JSONL: return jsonl() + if self is BlobStorageIntegrationFileType.PARQUET: + return parquet() diff --git a/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type_response.py b/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type_response.py index cfcafa5f3..57cc71969 100644 --- a/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type_response.py +++ b/langfuse/api/blob_storage_integrations/types/blob_storage_integration_file_type_response.py @@ -9,7 +9,7 @@ class BlobStorageIntegrationFileTypeResponse(enum.StrEnum): """ - File type reported for an existing integration. Includes `PARQUET`, which a project may enable through the Langfuse UI but cannot yet be set via this API (the request `fileType` omits it). + File type reported for an existing integration. """ JSON = "JSON"