jgVddlZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ejRejTdZ+GddZ,GddZ-y)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)BreakdownConfigPublic)FeedbackScoreNames)ProjectDetailed)ProjectMetricResponsePublic)ProjectPagePublic) ProjectPublic)ProjectStatsSummary)SpanFilterPublic)TokenUsageNames)TraceFilterPublic)TraceThreadFilterPublic)AsyncRawProjectsClientRawProjectsClient)"ProjectMetricRequestPublicInterval)$ProjectMetricRequestPublicMetricType)ProjectUpdateVisibility)ProjectWriteVisibility.ceZdZdefdZedefdZdddddddeje deje d eje d eje d eje de f d Zeedd d e dejedeje d eje ddf dZddde d eje defdZddde d eje ddfdZeeeddde d eje deje dejed eje ddf dZdddej.e d eje ddfdZddddeje d eje defdZddde d eje defdZeeeeeeeedd de dejedejed ejej@d!ejej@d"ejej.e!d#ejej.e"d$ejej.e#d%eje$d eje de%fd&Z&dddddddeje deje d eje d eje d eje de'f d'Z(ddd e d eje de)fd(Z*y))ProjectsClientclient_wrapperc&t||_yN)r)r _raw_clientselfrs v/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/projects/client.py__init__zProjectsClient.__init__s,NKreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawProjectsClient rr s r!with_raw_responsez ProjectsClient.with_raw_response!r#Npagesizenamesortingrequest_optionsr+r,r-r.r/cZ|jj|||||}|jS)a` Find projects Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] name : typing.Optional[str] sorting : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectPagePublic Project resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.find_projects() r*r find_projectsdatar r+r,r-r.r/ _responses r!r2zProjectsClient.find_projects,s7H$$22DtWo3 ~~r# visibility descriptionr/r7r8cX|jj||||}|jS)a, Create project Parameters ---------- name : str visibility : typing.Optional[ProjectWriteVisibility] description : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.create_project(name='name', ) r-r7r8r/rcreate_projectr3r r-r7r8r/r5s r!r<zProjectsClient.create_projectUs6@$$33*+Wf4 ~~r#r/idcT|jj||}|jS)a Get project by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectPublic Project resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.get_project_by_id(id='id', ) r>rget_project_by_idr3r r?r/r5s r!rBz ProjectsClient.get_project_by_idzs),$$66r?6[ ~~r#cT|jj||}|jS)a Delete project by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.delete_project_by_id(id='id', ) r>rdelete_project_by_idr3rCs r!rFz#ProjectsClient.delete_project_by_ids)*$$99"o9^ ~~r#r-r8r7r/cZ|jj|||||}|jS)aR Update project by id Parameters ---------- id : str name : typing.Optional[str] description : typing.Optional[str] visibility : typing.Optional[ProjectUpdateVisibility] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.update_project(id='id', ) rGrupdate_projectr3r r?r-r8r7r/r5s r!rJzProjectsClient.update_projects8F$$33 T{z[j4 ~~r#idscT|jj||}|jS)a Delete projects batch Parameters ---------- ids : typing.Sequence[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.delete_projects_batch(ids=['ids'], ) rLr/rdelete_projects_batchr3r rLr/r5s r!rPz$ProjectsClient.delete_projects_batchs*.$$::sTc:d ~~r# project_idsr/rScT|jj||}|jS)a4 Find Feedback Score names By Project Ids Parameters ---------- project_ids : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNames Feedback Scores resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.find_feedback_score_names_by_project_ids() rRr(find_feedback_score_names_by_project_idsr3r rSr/r5s r!rVz7ProjectsClient.find_feedback_score_names_by_project_idss10$$MM#_N ~~r#cT|jj||}|jS)a Find Token Usage names Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TokenUsageNames Token Usage names resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.find_token_usage_names(id='id', ) r>rfind_token_usage_namesr3rCs r!rZz%ProjectsClient.find_token_usage_names s*0$$;;BP_;` ~~r# metric_typeintervalinterval_start interval_end span_filters trace_filtersthread_filters breakdownr/r\r]r^r_r`rarbrcc d|jj||||||||| |  } | jS)a3 Gets specified metrics for a project Parameters ---------- id : str metric_type : typing.Optional[ProjectMetricRequestPublicMetricType] interval : typing.Optional[ProjectMetricRequestPublicInterval] interval_start : typing.Optional[dt.datetime] interval_end : typing.Optional[dt.datetime] span_filters : typing.Optional[typing.Sequence[SpanFilterPublic]] trace_filters : typing.Optional[typing.Sequence[TraceFilterPublic]] thread_filters : typing.Optional[typing.Sequence[TraceThreadFilterPublic]] breakdown : typing.Optional[BreakdownConfigPublic] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectMetricResponsePublic Project Metrics Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.get_project_metrics(id='id', ) r[rget_project_metricsr3 r r?r\r]r^r_r`rarbrcr/r5s r!rfz"ProjectsClient.get_project_metrics%sJf$$88 #)%%')+9  ~~r#cZ|jj|||||}|jS)ag Get Project Stats Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] name : typing.Optional[str] sorting : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsSummary Project Stats Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.get_project_stats() r*rget_project_statsr3r4s r!rjz ProjectsClient.get_project_statsfs7H$$66DtWo7 ~~r#cT|jj||}|jS)a Retrieve project Parameters ---------- name : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectDetailed Project resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.projects.retrieve_project(name='name', ) r-r/rretrieve_projectr3r r-r/r5s r!rnzProjectsClient.retrieve_projects*0$$554Q`5a ~~r#)+__name__ __module__ __qualname__rr"propertyrr(typingOptionalintstrrr r2OMITrr<r rBrFrrJSequencerPrrVrrZrrdtdatetimerrrrr rfr rjr rnr#r!rrs*L*;L #4  &*%)%)(,;?'ooc"'ooc" ' ooc" ' % ' 8' 'Z?C,0;? ##OO$:; # __S) #  8 # #J`dCV__^=\hu2cgsP^@_ko8&*,0?C;?& &ooc" & __S) & OO$;< & 8& &R`dooc*=C__^=\ 66:nr$ooc2LROO\jLk <NR+1??>+J >NRHL7;59KOMQTX<@;?? ?__%IJ ? //"DE ?  4 ?oobkk2?oofoo6F&GH?v7H'IJ?8O(PQ???#89? 8? %?H&*%)%)(,;?'ooc"'ooc" ' ooc" ' % ' 8' 'TPT-3__^-L r#rceZdZdefdZedefdZdddddddeje deje d eje d eje d eje de f d Zeedd d e dejedeje d eje ddf dZddde d eje defdZddde d eje ddfdZeeeddde d eje deje dejed eje ddf dZdddej.e d eje ddfdZddddeje d eje defdZddde d eje defdZeeeeeeeedd de dejedejed ejej@d!ejej@d"ejej.e!d#ejej.e"d$ejej.e#d%eje$d eje de%fd&Z&dddddddeje deje d eje d eje d eje de'f d'Z(ddd e d eje de)fd(Z*y))AsyncProjectsClientrc&t||_yr)rrrs r!r"zAsyncProjectsClient.__init__s1Pr#r$c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawProjectsClient r&r's r!r(z%AsyncProjectsClient.with_raw_responser)r#Nr*r+r,r-r.r/cvK|jj|||||d{}|jS7w)a Find projects Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] name : typing.Optional[str] sorting : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectPagePublic Project resource Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.find_projects() asyncio.run(main()) r*Nr1r4s r!r2z!AsyncProjectsClient.find_projectssEN**88DtWo9  ~~ $979r6r7r8ctK|jj||||d{}|jS7w)a Create project Parameters ---------- name : str visibility : typing.Optional[ProjectWriteVisibility] description : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.create_project(name='name', ) asyncio.run(main()) r:Nr;r=s r!r<z"AsyncProjectsClient.create_projectsDF**99*+Wf:  ~~ s #868r>r?cpK|jj||d{}|jS7w)aQ Get project by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectPublic Project resource Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.get_project_by_id(id='id', ) asyncio.run(main()) r>NrArCs r!rBz%AsyncProjectsClient.get_project_by_ids76**< None: await client.projects.delete_project_by_id(id='id', ) asyncio.run(main()) r>NrErCs r!rFz(AsyncProjectsClient.delete_project_by_id,s70**??Tc?dd ~~errGcvK|jj|||||d{}|jS7w)a Update project by id Parameters ---------- id : str name : typing.Optional[str] description : typing.Optional[str] visibility : typing.Optional[ProjectUpdateVisibility] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.update_project(id='id', ) asyncio.run(main()) rGNrIrKs r!rJz"AsyncProjectsClient.update_projectGsFL**99 T{z[j:  ~~ rrLcpK|jj||d{}|jS7w)aI Delete projects batch Parameters ---------- ids : typing.Sequence[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.delete_projects_batch(ids=['ids'], ) asyncio.run(main()) rNNrOrQs r!rPz)AsyncProjectsClient.delete_projects_batchrs74**@@SZi@jj ~~krrRrScpK|jj||d{}|jS7w)a Find Feedback Score names By Project Ids Parameters ---------- project_ids : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNames Feedback Scores resource Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.find_feedback_score_names_by_project_ids() asyncio.run(main()) rRNrUrWs r!rVz None: await client.projects.find_token_usage_names(id='id', ) asyncio.run(main()) r>NrYrCs r!rZz*AsyncProjectsClient.find_token_usage_namess76**AA"VeAff ~~grr[r\r]r^r_r`rarbrcc K|jj||||||||| |  d{} | jS7w)a Gets specified metrics for a project Parameters ---------- id : str metric_type : typing.Optional[ProjectMetricRequestPublicMetricType] interval : typing.Optional[ProjectMetricRequestPublicInterval] interval_start : typing.Optional[dt.datetime] interval_end : typing.Optional[dt.datetime] span_filters : typing.Optional[typing.Sequence[SpanFilterPublic]] trace_filters : typing.Optional[typing.Sequence[TraceFilterPublic]] thread_filters : typing.Optional[typing.Sequence[TraceThreadFilterPublic]] breakdown : typing.Optional[BreakdownConfigPublic] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectMetricResponsePublic Project Metrics Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.get_project_metrics(id='id', ) asyncio.run(main()) r[Nrergs r!rfz'AsyncProjectsClient.get_project_metricssXl**>> #)%%')+?   ~~  s )><>cvK|jj|||||d{}|jS7w)a Get Project Stats Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] name : typing.Optional[str] sorting : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsSummary Project Stats Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.get_project_stats() asyncio.run(main()) r*Nrir4s r!rjz%AsyncProjectsClient.get_project_statssEN**<<DtWo=  ~~ rcpK|jj||d{}|jS7w)aW Retrieve project Parameters ---------- name : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectDetailed Project resource Examples -------- from Opik import AsyncOpikApi import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.projects.retrieve_project(name='name', ) asyncio.run(main()) rlNrmros r!rnz$AsyncProjectsClient.retrieve_project=s76**;;Wf;gg ~~hr)+rprqrrrr"rsrr(rtrurvrwrr r2rxrr<r rBrFrrJryrPrrVrrZrrrzr{rrrrr rfr rjr rnr|r#r!r~r~s:Q*<Q #9  &*%)%)(,;?*ooc"*ooc" * ooc" * % * 8* *`?C,0;? &&OO$:; & __S) &  8 & &RNR+1??>+J <imSfooVdFequ>&*,0?C;?) )ooc" ) __S) ) OO$;< ) 8) )X`dooc*=C__^=\ <6:nr$ooc2LROO\jLk BNR+1??>+J DNRHL7;59KOMQTX<@;?B B__%IJ B //"DE B  4 Boobkk2Boofoo6F&GHBv7H'IJB8O(PQB??#89B 8B %BN&*%)%)(,;?*ooc"*ooc" * ooc" * % * 8* *ZPT-3__^-L r#r~).r{rzrtcore.client_wrapperrrcore.request_optionsrtypes.breakdown_config_publicrtypes.feedback_score_namesrtypes.project_detailedr $types.project_metric_response_publicr types.project_page_publicr types.project_publicr types.project_stats_summaryr types.span_filter_publicrtypes.token_usage_namesrtypes.trace_filter_publicr types.trace_thread_filter_publicr raw_clientrr,types.project_metric_request_public_intervalr/types.project_metric_request_public_metric_typertypes.project_update_visibilityrtypes.project_write_visibilityrcastAnyrxrr~r|r#r!rst G1A;4N90=759FA\aDBv{{6::s#KK\ nnr#