§ j?pãóÆ—ddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z ddl mZdd lmZejejd ¦«ZGd „d ¦«ZGd „d¦«ZdS)éNé)ÚTraceWithFullDetails)ÚAsyncClientWrapperÚSyncClientWrapper)ÚRequestOptionsé)ÚAsyncRawTraceClientÚRawTraceClient)ÚDeleteTraceResponse)ÚTraces.c!ó —eZdZdefd„Zedefd„¦«Zdddœdede j ed e j e de fd „Z dd œded e j e defd „Zdddddddddddddddd œde j ede j ede j ede j ede j ede j ejde j ejde j ede j e jee jefde j ede j ede j e jee jefde j ede j ed e j e def d„Zdd œde jed e j e defd„ZdS)Ú TraceClientÚclient_wrappercó0—t|¬¦«|_dS©N)r)r Ú _raw_client©Úselfrs úc/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/langfuse/api/trace/client.pyÚ__init__zTraceClient.__init__s€Ý)¸ÐHÑHÔHˆÔÐÐóÚreturncó—|jS)z“ Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawTraceClient ©r©rs rÚwith_raw_responsezTraceClient.with_raw_responseó €ðÔÐrN©ÚfieldsÚrequest_optionsÚtrace_idrr cóJ—|j |||¬¦«}|jS)aî Get a specific trace Parameters ---------- trace_id : str The unique langfuse identifier of a trace fields : typing.Optional[str] Comma-separated list of fields to include in the response. Available field groups: 'core' (always included), 'io' (input, output, metadata), 'scores', 'observations', 'metrics'. If not specified, all fields are returned. Example: 'core,scores,metrics'. Note: Excluded 'observations' or 'scores' fields return empty arrays; excluded 'metrics' returns -1 for 'totalCost' and 'latency'. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceWithFullDetails Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.trace.get( trace_id="traceId", ) r©rÚgetÚdata©rr!rr Ú _responses rr$zTraceClient.get s3€ðRÔ$×(Ò(Ø ˜V°_ð)ñ ô ˆ ðŒ~Ðr©r cóH—|j ||¬¦«}|jS)aL Delete a specific trace Parameters ---------- trace_id : str The unique langfuse identifier of the trace to delete request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- DeleteTraceResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.trace.delete( trace_id="traceId", ) r(©rÚdeleter%©rr!r r's rr+zTraceClient.deleteNs(€ðDÔ$×+Ò+¨HÀoÐ+ÑVÔVˆ ØŒ~Ðr©ÚpageÚlimitÚuser_idÚnameÚ session_idÚfrom_timestampÚ to_timestampÚorder_byÚtagsÚversionÚreleaseÚ environmentrÚfilterr r.r/r0r1r2r3r4r5r6r7r8r9r:cób—|j ||||||||| | | | | ||¬¦«}|jS)aM Get list of traces Parameters ---------- page : typing.Optional[int] Page number, starts at 1 limit : typing.Optional[int] Limit of items per page. If you encounter api issues due to too large page sizes, try to reduce the limit. user_id : typing.Optional[str] name : typing.Optional[str] session_id : typing.Optional[str] from_timestamp : typing.Optional[dt.datetime] Optional filter to only include traces with a trace.timestamp on or after a certain datetime (ISO 8601) to_timestamp : typing.Optional[dt.datetime] Optional filter to only include traces with a trace.timestamp before a certain datetime (ISO 8601) order_by : typing.Optional[str] Format of the string [field].[asc/desc]. Fields: id, timestamp, name, userId, release, version, public, bookmarked, sessionId. Example: timestamp.asc tags : typing.Optional[typing.Union[str, typing.Sequence[str]]] Only traces that include all of these tags will be returned. version : typing.Optional[str] Optional filter to only include traces with a certain version. release : typing.Optional[str] Optional filter to only include traces with a certain release. environment : typing.Optional[typing.Union[str, typing.Sequence[str]]] Optional filter for traces where the environment is one of the provided values. fields : typing.Optional[str] Comma-separated list of fields to include in the response. Available field groups: 'core' (always included), 'io' (input, output, metadata), 'scores', 'observations', 'metrics'. If not specified, all fields are returned. Example: 'core,scores,metrics'. Note: Excluded 'observations' or 'scores' fields return empty arrays; excluded 'metrics' returns -1 for 'totalCost' and 'latency'. filter : typing.Optional[str] JSON string containing an array of filter conditions. When provided, this takes precedence over query parameter filters (userId, name, sessionId, tags, version, release, environment, fromTimestamp, toTimestamp). ## Filter Structure Each filter condition has the following structure: ```json [ { "type": string, // Required. One of: "datetime", "string", "number", "stringOptions", "categoryOptions", "arrayOptions", "stringObject", "numberObject", "boolean", "null" "column": string, // Required. Column to filter on (see available columns below) "operator": string, // Required. Operator based on type: // - datetime: ">", "<", ">=", "<=" // - string: "=", "contains", "does not contain", "starts with", "ends with" // - stringOptions: "any of", "none of" // - categoryOptions: "any of", "none of" // - arrayOptions: "any of", "none of", "all of" // - number: "=", ">", "<", ">=", "<=" // - stringObject: "=", "contains", "does not contain", "starts with", "ends with" // - numberObject: "=", ">", "<", ">=", "<=" // - boolean: "=", "<>" // - null: "is null", "is not null" "value": any, // Required (except for null type). Value to compare against. Type depends on filter type "key": string // Required only for stringObject, numberObject, and categoryOptions types when filtering on nested fields like metadata } ] ``` ## Available Columns ### Core Trace Fields - `id` (string) - Trace ID - `name` (string) - Trace name - `timestamp` (datetime) - Trace timestamp - `userId` (string) - User ID - `sessionId` (string) - Session ID - `environment` (string) - Environment tag - `version` (string) - Version tag - `release` (string) - Release tag - `tags` (arrayOptions) - Array of tags - `bookmarked` (boolean) - Bookmark status ### Structured Data - `metadata` (stringObject/numberObject/categoryOptions) - Metadata key-value pairs. Use `key` parameter to filter on specific metadata keys. ### Aggregated Metrics (from observations) These metrics are aggregated from all observations within the trace: - `latency` (number) - Latency in seconds (time from first observation start to last observation end) - `inputTokens` (number) - Total input tokens across all observations - `outputTokens` (number) - Total output tokens across all observations - `totalTokens` (number) - Total tokens (alias: `tokens`) - `inputCost` (number) - Total input cost in USD - `outputCost` (number) - Total output cost in USD - `totalCost` (number) - Total cost in USD ### Observation Level Aggregations These fields aggregate observation levels within the trace: - `level` (string) - Highest severity level (ERROR > WARNING > DEFAULT > DEBUG) - `warningCount` (number) - Count of WARNING level observations - `errorCount` (number) - Count of ERROR level observations - `defaultCount` (number) - Count of DEFAULT level observations - `debugCount` (number) - Count of DEBUG level observations ### Scores (requires join with scores table) - `scores_avg` (number) - Average of numeric scores (alias: `scores`) - `score_categories` (categoryOptions) - Categorical score values ## Filter Examples ```json [ { "type": "datetime", "column": "timestamp", "operator": ">=", "value": "2024-01-01T00:00:00Z" }, { "type": "string", "column": "userId", "operator": "=", "value": "user-123" }, { "type": "number", "column": "totalCost", "operator": ">=", "value": 0.01 }, { "type": "arrayOptions", "column": "tags", "operator": "all of", "value": ["production", "critical"] }, { "type": "stringObject", "column": "metadata", "key": "customer_tier", "operator": "=", "value": "enterprise" } ] ``` ## Performance Notes - Filtering on `userId`, `sessionId`, or `metadata` may enable skip indexes for better query performance - Score filters require a join with the scores table and may impact query performance request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Traces Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.trace.list() r-©rÚlistr%©rr.r/r0r1r2r3r4r5r6r7r8r9rr:r r's rr=zTraceClient.listssY€ðxÔ$×)Ò)ØØØØØ!Ø)Ø%ØØØØØ#ØØØ+ð*ñ ô ˆ ð"Œ~ÐrÚ trace_idscóH—|j ||¬¦«}|jS)a\ Delete multiple traces Parameters ---------- trace_ids : typing.Sequence[str] List of trace IDs to delete request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- DeleteTraceResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.trace.delete_multiple( trace_ids=["traceIds", "traceIds"], ) ©r?r ©rÚdelete_multipler%©rr?r r's rrCzTraceClient.delete_multipleBs1€ðJÔ$×4Ò4Ø°ð5ñ ô ˆ ðŒ~Ðr)Ú__name__Ú __module__Ú __qualname__rrÚpropertyr rÚstrÚtypingÚOptionalrrr$r r+ÚintÚdtÚdatetimeÚUnionÚSequencer r=rC©rrrrs　€€€ðIÐ*;ðIðIðIðIðð  >ð ð ð ñ„Xð ð(,Ø;?ð ,ð,ð,àð,ð” Ô$ð ,ð  œ¨Ô8ð ,ð ð ,ð,ð,ð,ð^TXð#ð#ð#Øð#Ø17´ÀÔ1Pð#à ð#ð#ð#ð#ðP&*Ø&*Ø(,Ø%)Ø+/Ø7;Ø59Ø)-ØIMØ(,Ø(,ØPTØ'+Ø'+Ø;?ð#MðMðMðŒo˜cÔ"ðMðŒ˜sÔ#ð Mð ” Ô%ð Mð Œo˜cÔ"ð Mð”O CÔ(ðM𜨬 Ô4ðMð”o b¤kÔ2ðMð”/ #Ô&ðMðŒo˜fœl¨3°´ÀÔ0DÐ+DÔEÔFðMð” Ô%ðMð” Ô%ðMð”_ V¤\°#°v´ÀsÔ7KÐ2KÔ%LÔMðMð” Ô$ðMð ” Ô$ð!Mð" œ¨Ô8ð#Mð$ ð%MðMðMðMðf<@ð (ð(ð(ð”? 3Ô'ð(𠜨Ô8ð (ð ð (ð(ð(ð(ð(ð(rrc!ó —eZdZdefd„Zedefd„¦«Zdddœdede j ed e j e de fd „Z dd œded e j e defd „Zdddddddddddddddd œde j ede j ede j ede j ede j ede j ejde j ejde j ede j e jee jefde j ede j ede j e jee jefde j ede j ed e j e def d„Zdd œde jed e j e defd„ZdS)ÚAsyncTraceClientrcó0—t|¬¦«|_dSr)r rrs rrzAsyncTraceClient.__init__ns€Ý.¸nÐMÑMÔMˆÔÐÐrrcó—|jS)z˜ Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawTraceClient rrs rrz"AsyncTraceClient.with_raw_responseqrrNrr!rr cƒóZK—|j |||¬¦«ƒd{V—†}|jS)ad Get a specific trace Parameters ---------- trace_id : str The unique langfuse identifier of a trace fields : typing.Optional[str] Comma-separated list of fields to include in the response. Available field groups: 'core' (always included), 'io' (input, output, metadata), 'scores', 'observations', 'metrics'. If not specified, all fields are returned. Example: 'core,scores,metrics'. Note: Excluded 'observations' or 'scores' fields return empty arrays; excluded 'metrics' returns -1 for 'totalCost' and 'latency'. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceWithFullDetails Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.trace.get( trace_id="traceId", ) asyncio.run(main()) rNr#r&s rr$zAsyncTraceClient.get|sUèè€ðbÔ*×.Ò.Ø ˜V°_ð/ñ ô ð ð ð ð ð ð ˆ ðŒ~Ðrr(cƒóXK—|j ||¬¦«ƒd{V—†}|jS)a Delete a specific trace Parameters ---------- trace_id : str The unique langfuse identifier of the trace to delete request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- DeleteTraceResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.trace.delete( trace_id="traceId", ) asyncio.run(main()) r(Nr*r,s rr+zAsyncTraceClient.delete²sSèè€ðTÔ*×1Ò1Ø  oð2ñ ô ð ð ð ð ð ð ˆ ðŒ~Ðrr-r.r/r0r1r2r3r4r5r6r7r8r9r:cƒórK—|j ||||||||| | | | | ||¬¦«ƒd{V—†}|jS)a» Get list of traces Parameters ---------- page : typing.Optional[int] Page number, starts at 1 limit : typing.Optional[int] Limit of items per page. If you encounter api issues due to too large page sizes, try to reduce the limit. user_id : typing.Optional[str] name : typing.Optional[str] session_id : typing.Optional[str] from_timestamp : typing.Optional[dt.datetime] Optional filter to only include traces with a trace.timestamp on or after a certain datetime (ISO 8601) to_timestamp : typing.Optional[dt.datetime] Optional filter to only include traces with a trace.timestamp before a certain datetime (ISO 8601) order_by : typing.Optional[str] Format of the string [field].[asc/desc]. Fields: id, timestamp, name, userId, release, version, public, bookmarked, sessionId. Example: timestamp.asc tags : typing.Optional[typing.Union[str, typing.Sequence[str]]] Only traces that include all of these tags will be returned. version : typing.Optional[str] Optional filter to only include traces with a certain version. release : typing.Optional[str] Optional filter to only include traces with a certain release. environment : typing.Optional[typing.Union[str, typing.Sequence[str]]] Optional filter for traces where the environment is one of the provided values. fields : typing.Optional[str] Comma-separated list of fields to include in the response. Available field groups: 'core' (always included), 'io' (input, output, metadata), 'scores', 'observations', 'metrics'. If not specified, all fields are returned. Example: 'core,scores,metrics'. Note: Excluded 'observations' or 'scores' fields return empty arrays; excluded 'metrics' returns -1 for 'totalCost' and 'latency'. filter : typing.Optional[str] JSON string containing an array of filter conditions. When provided, this takes precedence over query parameter filters (userId, name, sessionId, tags, version, release, environment, fromTimestamp, toTimestamp). ## Filter Structure Each filter condition has the following structure: ```json [ { "type": string, // Required. One of: "datetime", "string", "number", "stringOptions", "categoryOptions", "arrayOptions", "stringObject", "numberObject", "boolean", "null" "column": string, // Required. Column to filter on (see available columns below) "operator": string, // Required. Operator based on type: // - datetime: ">", "<", ">=", "<=" // - string: "=", "contains", "does not contain", "starts with", "ends with" // - stringOptions: "any of", "none of" // - categoryOptions: "any of", "none of" // - arrayOptions: "any of", "none of", "all of" // - number: "=", ">", "<", ">=", "<=" // - stringObject: "=", "contains", "does not contain", "starts with", "ends with" // - numberObject: "=", ">", "<", ">=", "<=" // - boolean: "=", "<>" // - null: "is null", "is not null" "value": any, // Required (except for null type). Value to compare against. Type depends on filter type "key": string // Required only for stringObject, numberObject, and categoryOptions types when filtering on nested fields like metadata } ] ``` ## Available Columns ### Core Trace Fields - `id` (string) - Trace ID - `name` (string) - Trace name - `timestamp` (datetime) - Trace timestamp - `userId` (string) - User ID - `sessionId` (string) - Session ID - `environment` (string) - Environment tag - `version` (string) - Version tag - `release` (string) - Release tag - `tags` (arrayOptions) - Array of tags - `bookmarked` (boolean) - Bookmark status ### Structured Data - `metadata` (stringObject/numberObject/categoryOptions) - Metadata key-value pairs. Use `key` parameter to filter on specific metadata keys. ### Aggregated Metrics (from observations) These metrics are aggregated from all observations within the trace: - `latency` (number) - Latency in seconds (time from first observation start to last observation end) - `inputTokens` (number) - Total input tokens across all observations - `outputTokens` (number) - Total output tokens across all observations - `totalTokens` (number) - Total tokens (alias: `tokens`) - `inputCost` (number) - Total input cost in USD - `outputCost` (number) - Total output cost in USD - `totalCost` (number) - Total cost in USD ### Observation Level Aggregations These fields aggregate observation levels within the trace: - `level` (string) - Highest severity level (ERROR > WARNING > DEFAULT > DEBUG) - `warningCount` (number) - Count of WARNING level observations - `errorCount` (number) - Count of ERROR level observations - `defaultCount` (number) - Count of DEFAULT level observations - `debugCount` (number) - Count of DEBUG level observations ### Scores (requires join with scores table) - `scores_avg` (number) - Average of numeric scores (alias: `scores`) - `score_categories` (categoryOptions) - Categorical score values ## Filter Examples ```json [ { "type": "datetime", "column": "timestamp", "operator": ">=", "value": "2024-01-01T00:00:00Z" }, { "type": "string", "column": "userId", "operator": "=", "value": "user-123" }, { "type": "number", "column": "totalCost", "operator": ">=", "value": 0.01 }, { "type": "arrayOptions", "column": "tags", "operator": "all of", "value": ["production", "critical"] }, { "type": "stringObject", "column": "metadata", "key": "customer_tier", "operator": "=", "value": "enterprise" } ] ``` ## Performance Notes - Filtering on `userId`, `sessionId`, or `metadata` may enable skip indexes for better query performance - Score filters require a join with the scores table and may impact query performance request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Traces Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.trace.list() asyncio.run(main()) r-Nr<r>s rr=zAsyncTraceClient.listás{èè€ðHÔ*×/Ò/ØØØØØ!Ø)Ø%ØØØØØ#ØØØ+ð0ñ ô ð ð ð ð ð ð ˆ ð"Œ~Ðrr?cƒóXK—|j ||¬¦«ƒd{V—†}|jS)aÒ Delete multiple traces Parameters ---------- trace_ids : typing.Sequence[str] List of trace IDs to delete request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- DeleteTraceResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.trace.delete_multiple( trace_ids=["traceIds", "traceIds"], ) asyncio.run(main()) rANrBrDs rrCz AsyncTraceClient.delete_multiple¸sSèè€ðZÔ*×:Ò:Ø°ð;ñ ô ð ð ð ð ð ð ˆ ðŒ~Ðr)rErFrGrrrHr rrIrJrKrrr$r r+rLrMrNrOrPr r=rCrQrrrSrSms䀀€€€ðNÐ*<ðNðNðNðNðð Ð#6ð ð ð ñ„Xð ð(,Ø;?ð 4ð4ð4àð4ð” Ô$ð 4ð  œ¨Ô8ð 4ð ð 4ð4ð4ð4ðnTXð-ð-ð-Øð-Ø17´ÀÔ1Pð-à ð-ð-ð-ð-ðd&*Ø&*Ø(,Ø%)Ø+/Ø7;Ø59Ø)-ØIMØ(,Ø(,ØPTØ'+Ø'+Ø;?ð#UðUðUðŒo˜cÔ"ðUðŒ˜sÔ#ð Uð ” Ô%ð Uð Œo˜cÔ"ð Uð”O CÔ(ðU𜨬 Ô4ðUð”o b¤kÔ2ðUð”/ #Ô&ðUðŒo˜fœl¨3°´ÀÔ0DÐ+DÔEÔFðUð” Ô%ðUð” Ô%ðUð”_ V¤\°#°v´ÀsÔ7KÐ2KÔ%LÔMðUð” Ô$ðUð ” Ô$ð!Uð" œ¨Ô8ð#Uð$ ð%UðUðUðUðv<@ð 0ð0ð0ð”? 3Ô'ð0𠜨Ô8ð 0ð ð 0ð0ð0ð0ð0ð0rrS)rNrMrJÚ%commons.types.trace_with_full_detailsrÚcore.client_wrapperrrÚcore.request_optionsrÚ raw_clientr r Útypes.delete_trace_responser Ú types.tracesr ÚcastÚAnyÚOMITrrSrQrrúrcsððÐÐÐØ € € € àHÐHÐHÐHÐHÐHØGÐGÐGÐGÐGÐGÐGÐGØ1Ð1Ð1Ð1Ð1Ð1Ø;Ð;Ð;Ð;Ð;Ð;Ð;Ð;Ø<Ð<Ð<Ð<Ð<Ð<Ø Ð Ð Ð Ð Ð ð€v„{6”:˜sÑ#Ô#€ðYðYðYðYðYñYôYðYðx {ð{ð{ð{ð{ñ{ô{ð{ð{ð{r