jFddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z dd lmZmZdd lmZejejd ZGd d ZGddZdS)N)Model)ModelUsageUnit)PricingTierInput)AsyncClientWrapperSyncClientWrapper)RequestOptions)AsyncRawModelsClientRawModelsClient)PaginatedModels.c8eZdZdefdZedefdZeeeeeeeedd de de d e j e j d e j ed e j ed e j ed e j ede j e jede j e de j e jde j edefdZddddde j ede j ede j edefdZddde de j edefdZddde de j eddfdZdS) ModelsClientclient_wrapperc0t||_dSN)r)r _raw_clientselfrs d/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/langfuse/api/models/client.py__init__zModelsClient.__init__s*.IIIreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawModelsClient rrs rwith_raw_responsezModelsClient.with_raw_response rN start_dateunit input_price output_price total_price pricing_tiers tokenizer_idtokenizer_configrequest_options model_name match_patternr r!r"r#r$r%r&r'r(c Z|j||||||||| | |  } | jS)a Create a model Parameters ---------- model_name : str Name of the model definition. If multiple with the same name exist, they are applied in the following order: (1) custom over built-in, (2) newest according to startTime where model.startTimes rrAzModelsClient.deletes(B$++B+PP ~r)__name__ __module__ __qualname__rrpropertyr rOMITstrtypingOptionaldtdatetimerfloatSequencerAnyr rr.intr r7r=rArrrrs]J*;JJJJ ?   X 4804.2/3.2LP-18<;?hhhh h OBK0 h on- h_U+hoe,h_U+hv7G'HIhoc*h!/&*5h 8h hhhhZ&*&*;? ***oc"*s# *  8 *  ****ZNR""""+1?>+J" """"JNR""""+1?>+J" """"""rrc8eZdZdefdZedefdZeeeeeeeedd de de d e j e j d e j ed e j ed e j ed e j ede j e jede j e de j e jde j edefdZddddde j ede j ede j edefdZddde de j edefdZddde de j eddfdZdS)AsyncModelsClientrc0t||_dSr)r rrs rrzAsyncModelsClient.__init__s/~NNNrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawModelsClient rrs rrz#AsyncModelsClient.with_raw_responserrNrr)r*r r!r"r#r$r%r&r'r(c jK|j||||||||| | |  d{V} | jS)a Create a model Parameters ---------- model_name : str Name of the model definition. If multiple with the same name exist, they are applied in the following order: (1) custom over built-in, (2) newest according to startTime where model.startTime None: await client.models.create( model_name="modelName", match_pattern="matchPattern", ) asyncio.run(main()) r,Nr-r0s rr.zAsyncModelsClient.createsoF*11!'!#%#'%-+2         ~rr2r3r4cZK|j|||d{V}|jS)a Get all models Parameters ---------- page : typing.Optional[int] page number, starts at 1 limit : typing.Optional[int] limit of items per page request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- PaginatedModels 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.models.list() asyncio.run(main()) r2Nr6r8s rr7zAsyncModelsClient.listsU^*//UO0        ~rr9r:cXK|j||d{V}|jS)aS Get a model Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Model 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.models.get( id="id", ) asyncio.run(main()) r9Nr<r>s rr=zAsyncModelsClient.gets>R*..r?.SSSSSSSS ~rcXK|j||d{V}|jS)a Delete a model. Cannot delete models managed by Langfuse. You can create your own definition with the same modelName to override the definition though. Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None 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.models.delete( id="id", ) asyncio.run(main()) r9Nr@r>s rrAzAsyncModelsClient.deletes>R*11"o1VVVVVVVV ~r)rBrCrDrrrEr rrFrGrHrIrJrKrrLrMrrNr rr.rOr r7r=rArPrrrRrRs^O*<OOOO #7   X 4804.2/3.2LP-18<;?pppp p OBK0 p on- p_U+poe,p_U+pv7G'HIpoc*p!/&*5p 8p ppppj&*&*;? 222oc"2s# 2  8 2  2222jNR****+1?>+J* ****ZNR****+1?>+J* ******rrR)rKrJrHcommons.types.modelrcommons.types.model_usage_unitr commons.types.pricing_tier_inputrcore.client_wrapperrrcore.request_optionsr raw_clientr r types.paginated_modelsr castrNrFrrRrPrrras* '''''';;;;;;??????GGGGGGGG111111========333333v{6:s##kkkkkkkk\KKKKKKKKKKr