jIeddlmZddlZddlZddlmZmZejrddlm Z m Z ddl m Z m Z ddlmZmZddlmZmZdd lmZmZdd lmZmZdd lmZmZdd lmZmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9m:Z:ddl;mm?Z?m@Z@ddlAmBZBmCZCddlDmEZEmFZFddlGmHZHmIZIddlJmKZKmLZLddlMmNZNmOZOGddZPGdd ZQdS)!) annotationsN)AsyncClientWrapperSyncClientWrapper)AnnotationQueuesClientAsyncAnnotationQueuesClient)"AsyncBlobStorageIntegrationsClientBlobStorageIntegrationsClient)AsyncCommentsClientCommentsClient)AsyncDatasetItemsClientDatasetItemsClient)AsyncDatasetRunItemsClientDatasetRunItemsClient)AsyncDatasetsClientDatasetsClient)AsyncHealthClient HealthClient)AsyncIngestionClientIngestionClient)AsyncLegacyClient LegacyClient)AsyncLlmConnectionsClientLlmConnectionsClient)AsyncMediaClient MediaClient)AsyncMetricsClient MetricsClient)AsyncModelsClient ModelsClient)AsyncObservationsClientObservationsClient)AsyncOpentelemetryClientOpentelemetryClient)AsyncOrganizationsClientOrganizationsClient)AsyncProjectsClientProjectsClient)AsyncPromptVersionClientPromptVersionClient)AsyncPromptsClient PromptsClient)AsyncScimClient ScimClient)AsyncScoreConfigsClientScoreConfigsClient)AsyncScoresClient ScoresClient)AsyncSessionsClientSessionsClient)AsyncTraceClient TraceClientc @eZdZdZdddddddddd d/dZedZedZedZedZ edZ edZ edZ edZ edZed Zed!Zed"Zed#Zed$Zed%Zed&Zed'Zed(Zed)Zed*Zed+Zed,Zed-Zed.ZdS)0 LangfuseAPIa Use this class to access the different functions within the SDK. You can instantiate any number of clients with different configuration that will propagate to these functions. Parameters ---------- base_url : str The base url to use for requests from the client. x_langfuse_sdk_name : typing.Optional[str] x_langfuse_sdk_version : typing.Optional[str] x_langfuse_public_key : typing.Optional[str] username : typing.Optional[typing.Union[str, typing.Callable[[], str]]] password : typing.Optional[typing.Union[str, typing.Callable[[], str]]] headers : typing.Optional[typing.Dict[str, str]] Additional headers to send with every request. timeout : typing.Optional[float] The timeout to be used, in seconds, for requests. By default the timeout is 60 seconds, unless a custom httpx client is used, in which case this default is not enforced. follow_redirects : typing.Optional[bool] Whether the default httpx client follows redirects or not, this is irrelevant if a custom httpx client is passed in. httpx_client : typing.Optional[httpx.Client] The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration. 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", ) NT x_langfuse_sdk_namex_langfuse_sdk_versionx_langfuse_public_keyusernamepasswordheaderstimeoutfollow_redirects httpx_clientbase_urlstrr:typing.Optional[str]r;r<r=r?&typing.Optional[typing.Dict[str, str]]r@typing.Optional[float]rAtyping.Optional[bool]rBtyping.Optional[httpx.Client]c ||n| dn | jj} t|||||||| | n,| tj| | ntj| |  |_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_dSN<)r@rA)r@) rCr:r;r<r=r>r?rBr@)r@readrhttpxClient_client_wrapper_annotation_queues_blob_storage_integrations _comments_dataset_items_dataset_run_items _datasets_health _ingestion_legacy_llm_connections_media_metrics_models _observations_opentelemetry_organizations _projects_prompt_version_prompts_scim_score_configs_scores _sessions_trace selfrCr:r;r<r=r>r?r@rArB_defaulted_timeouts c/lsinfo/ai/hellotax_ai/data_center/backend/venv/lib/python3.11/site-packages/langfuse/api/client.py__init__zLangfuseAPI.__init__Vsi " G#%*  1 3#9"7'&  +*=M&8999&   "LP  ';?CGJN:>6: <@6: GK48 8< 6: BFDHDH:>EI8< 26 CG6: :>48 cV|jddlm}||j|_|jS)Nr)rclient_wrapper)rRannotation_queues.clientrrQ)rkrs rmannotation_queueszLangfuseAPI.annotation_queuessH  " * H H H H H H&<&<#3'''D #&&rocV|jddlm}||j|_|jS)Nr)r rq)rS blob_storage_integrations.clientr rQ)rkr s rmblob_storage_integrationsz%LangfuseAPI.blob_storage_integrationssH  * 2 W W W W W W.K.K#3///D +..rocV|jddlm}||j|_|jS)Nr)r rq)rTcomments.clientr rQ)rkr s rmcommentszLangfuseAPI.comments; > ! 7 7 7 7 7 7+^4;OPPPDN~rocV|jddlm}||j|_|jS)Nr)rrq)rUdataset_items.clientrrQ)rkrs rm dataset_itemszLangfuseAPI.dataset_itemsH   & @ @ @ @ @ @"4"4#3###D ""rocV|jddlm}||j|_|jS)Nr)rrq)rVdataset_run_items.clientrrQ)rkrs rmdataset_run_itemszLangfuseAPI.dataset_run_itemssH  " * G G G G G G&;&;#3'''D #&&rocV|jddlm}||j|_|jS)Nr)rrq)rWdatasets.clientrrQ)rkrs rmdatasetszLangfuseAPI.datasetsr{rocV|jddlm}||j|_|jS)Nr)rrq)rX health.clientrrQ)rkrs rmhealthzLangfuseAPI.health; <  3 3 3 3 3 3'rFr?rGr@rHrArIrBrJ__name__ __module__ __qualname____doc__rnpropertyrtrwrzr~rrrrrrrrrrrrrrrrrrrrrormr8r8.s%%V597;6:QUQU:>*.266:?9?9?9?9?9?9B''X'//X/X##X#''X'XXXX%%X%XXX""X"##X###X#X$$X$XX##X#XXXror8c @eZdZdZdddddddddd d/dZedZedZedZedZ edZ edZ edZ edZ edZed Zed!Zed"Zed#Zed$Zed%Zed&Zed'Zed(Zed)Zed*Zed+Zed,Zed-Zed.ZdS)0AsyncLangfuseAPIa Use this class to access the different functions within the SDK. You can instantiate any number of clients with different configuration that will propagate to these functions. Parameters ---------- base_url : str The base url to use for requests from the client. x_langfuse_sdk_name : typing.Optional[str] x_langfuse_sdk_version : typing.Optional[str] x_langfuse_public_key : typing.Optional[str] username : typing.Optional[typing.Union[str, typing.Callable[[], str]]] password : typing.Optional[typing.Union[str, typing.Callable[[], str]]] headers : typing.Optional[typing.Dict[str, str]] Additional headers to send with every request. timeout : typing.Optional[float] The timeout to be used, in seconds, for requests. By default the timeout is 60 seconds, unless a custom httpx client is used, in which case this default is not enforced. follow_redirects : typing.Optional[bool] Whether the default httpx client follows redirects or not, this is irrelevant if a custom httpx client is passed in. httpx_client : typing.Optional[httpx.AsyncClient] The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration. Examples -------- 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", ) NTr9rCrDr:rEr;r<r=rFr>r?rGr@rHrArIrB"typing.Optional[httpx.AsyncClient]c ||n| dn | jj} t|||||||| | n,| tj| | ntj| |  |_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_dSrL)r@rNrrO AsyncClientrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjs rmrnzAsyncLangfuseAPI.__init__sm " G#%*  2 3#9"7'&  +"*=M"+=>>>&   "QU  '@DHLOS?C;? AE;? LP9= =A ;? GKIMIM?CJN=A 7; HL;? ?C9= rocV|jddlm}||j|_|jS)Nr)rrq)rRrsrrQ)rkrs rmrtz"AsyncLangfuseAPI.annotation_queuessH  " * M M M M M M&A&A#3'''D #&&rocV|jddlm}||j|_|jS)Nr)r rq)rSrvr rQ)rkr s rmrwz*AsyncLangfuseAPI.blob_storage_integrationssW  * 2      /Q.P#3///D +..rocV|jddlm}||j|_|jS)Nr)r rq)rTryr rQ)rkr s rmrzzAsyncLangfuseAPI.comments< > ! < < < < < <00@TUUUDN~rocV|jddlm}||j|_|jS)Nr)r rq)rUr}r rQ)rkr s rmr~zAsyncLangfuseAPI.dataset_itemsH   & E E E E E E"9"9#3###D ""rocV|jddlm}||j|_|jS)Nr)rrq)rVrrrQ)rkrs rmrz"AsyncLangfuseAPI.dataset_run_itemssH  " * L L L L L L&@&@#3'''D #&&rocV|jddlm}||j|_|jS)Nr)rrq)rWrrrQ)rkrs rmrzAsyncLangfuseAPI.datasetsrrocV|jddlm}||j|_|jS)Nr)rrq)rXrrrQ)rkrs rmrzAsyncLangfuseAPI.health < <  8 8 8 8 8 8,,D > > > > >22$BVWWWDOrocV|jddlm}||j|_|jS)Nr)rrq)rZrrrQ)rkrs rmrzAsyncLangfuseAPI.legacyrrocV|jddlm}||j|_|jS)Nr)rrq)r[rrrQ)rkrs rmrz AsyncLangfuseAPI.llm_connections%sH  ( I I I I I I$=$=#3%%%D !$$rocV|jddlm}||j|_|jS)Nr)rrq)r\rrrQ)rkrs rmrzAsyncLangfuseAPI.media/< ;  6 6 6 6 6 6**$:NOOODK{rocV|jddlm}||j|_|jS)Nr)rrq)r]rrrQ)rkrs rmrzAsyncLangfuseAPI.metrics7< = : : : : : :..d>RSSSDM}rocV|jddlm}||j|_|jS)Nr)rrq)r^rrrQ)rkrs rmrzAsyncLangfuseAPI.models?rrocV|jddlm}||j|_|jS)Nr)r!rq)r_rr!rQ)rkr!s rmrzAsyncLangfuseAPI.observationsGsH   % D D D D D D!8!8#3"""D !!rocV|jddlm}||j|_|jS)Nr)r#rq)r`rr#rQ)rkr#s rmrzAsyncLangfuseAPI.opentelemetryQH   & F F F F F F":":#3###D ""rocV|jddlm}||j|_|jS)Nr)r%rq)rarr%rQ)rkr%s rmrzAsyncLangfuseAPI.organizations[rrocV|jddlm}||j|_|jS)Nr)r'rq)rbrr'rQ)rkr's rmrzAsyncLangfuseAPI.projectserrocV|jddlm}||j|_|jS)Nr)r)rq)rcrr)rQ)rkr)s rmrzAsyncLangfuseAPI.prompt_versionmsH   ' G G G G G G#;#;#3$$$D ##rocV|jddlm}||j|_|jS)Nr)r+rq)rdrr+rQ)rkr+s rmrzAsyncLangfuseAPI.promptswrrocV|jddlm}||j|_|jS)Nr)r-rq)rerr-rQ)rkr-s rmrzAsyncLangfuseAPI.scims; :  4 4 4 4 4 4(8LMMMDJzrocV|jddlm}||j|_|jS)Nr)r/rq)rfrr/rQ)rkr/s rmrzAsyncLangfuseAPI.score_configsrrocV|jddlm}||j|_|jS)Nr)r1rq)rgrr1rQ)rkr1s rmrzAsyncLangfuseAPI.scoresrrocV|jddlm}||j|_|jS)Nr)r3rq)rhrr3rQ)rkr3s rmrzAsyncLangfuseAPI.sessionsrrocV|jddlm}||j|_|jS)Nr)r5rq)rirr5rQ)rkr5s rmrzAsyncLangfuseAPI.tracerro)rCrDr:rEr;rEr<rEr=rFr>rFr?rGr@rHrArIrBrrrrormrrjs%%V597;6:QUQU:>*.26;??>?>?>?>?>?>B''X' / /X /X##X#''X'XXXX%%X%XXX""X"##X###X#X$$X$XX##X#XXXror)R __future__rtypingrOcore.client_wrapperrr TYPE_CHECKINGrsrrrvr r ryr r r}r rrrrrrrrrrrrrrrrrrrrrrrrrrrr rr!r"rr#r$rr%r&rr'r(rr)r*rr+r,rr-r.rr/r0rr1r2rr3r4rr5r6r8rrrormrs1#""""" FFFFFFFF !<EDDDDDDDQQQQQQQQEDDDDDDD>>>>>>>>GGGGGGGG>>>>>>>>WWWWWWWW;;;;;;;;AAAAAAAA>>>>>>>>PPPPPPPPSSSSSSSSSSSSSSSSDDDDDDDDTTTTTTTTAAAAAAAA88888888QQQQQQQQ>>>>>>>>DDDDDDDD;;;;;;;;yyyyyyyyx }}}}}}}}}}ro