jьddlZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddl m!Z!ddl"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddl0m1Z1m2Z2ejfejhdZ5GddZ6GddZ7y) N)AsyncClientWrapperSyncClientWrapper)RequestOptions)Comment) ErrorInfo)ErrorInfoWrite)FeedbackScoreBatchItem)FeedbackScoreBatchItemThread)FeedbackScoreNamesPublic)FeedbackScoreSource)JsonListString)JsonListStringWrite)ProjectStatsPublic)TraceFilterPublic)TracePagePublic) TracePublic) TraceThread)TraceThreadFilter)TraceThreadPage)TraceThreadUpdate) TraceUpdate) TraceWrite) ValueEntry)AsyncRawTracesClientRawTracesClient.c!leZdZdefdZedefdZeeeeeddde de d e je d e je jd e je jd e je d e je de jeddfdZeeeeeddde de d e je d e je jd e je jd e je d e je de jeddfdZeeeeeeeddd e de dedede je de je d e je jd e je jd e je d e je de je j&e efde jeddfdZddde j,ede jeddfdZeddde j,e dede jede jeddf d Zeddde j,e dede jede jeddf d!Zeeeedd"d#e je d$e je d%e je d&e je j,e de jeddf d'Zdddddddddddddd( d)e jed*e jed#e je d$e je d+e je d,e jed-e jed.e je d/e je d0e je d1e je jd2e je jde jede fd3Z!eeeeeeeeeeeedd4 d5e jd e je d#e je de je d6e je jd7e je"d8e je"d9e je"d:e je j,e d;e je#d e je jdd e d-e jede jede%fd?Z&ddd e de jeddfd@Z'eeeeeeeeeeeeeddAd e d#e je d$e je de je d6e je jd7e je(d8e je(d9e je(d:e je j,e dBe je j,e dCe je j,e d;e je)d%e je dddd^e j,e?de jeddfd_Z@ddd^e j,eAde jeddfd`ZBeeeeeeeeedda d#e je d$e je d+e je j,eCdbe je dce jed,e jed-e jed1e je jd2e je jde jede jeEfddZFeeeeeeeeedde d#e je d$e je d+e je j,eGdfe je dce jed,e jed-e jed1e je jd2e je jde jede jeEfdgZHeeeddhdie d:e je j,e dBe je j,e dCe je j,e de jeddf djZIeeeeedddTe de d e je d e je jd e je jd e je d e je de jeddfdkZJeeeeedddTe de d e je d e je jd e je jd e je d e je de jeddfdlZKy)m TracesClientclient_wrapperc&t||_yN)r )r _raw_clientselfr s t/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/traces/client.py__init__zTracesClient.__init__#s*.Ireturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawTracesClient r#r%s r&with_raw_responsezTracesClient.with_raw_response&r(Nid created_atlast_updated_at created_bylast_updated_byrequest_optionsid_textr0r1r2r3r4r5c `|jj||||||||} | jS)a Add thread comment Parameters ---------- id_ : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.add_thread_comment(id_='id', text='text', ) r7r0r1r2r3r4r5r#add_thread_commentdata r%r6r7r0r1r2r3r4r5 _responses r&r;zTracesClient.add_thread_comment1sDX$$77 !+!++8  ~~r(c `|jj||||||||} | jS)a Add trace comment Parameters ---------- id_ : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.add_trace_comment(id_='id', text='text', ) r9r#add_trace_commentr<r=s r&rAzTracesClient.add_trace_commentisDX$$66 !+!++7  ~~r( category_namereasonr1r2r3r4value_by_authorr5namevaluesourcerCrDrEc h|jj||||||||| | | |  } | jS)a Add trace feedback score Parameters ---------- id : str name : str value : float source : FeedbackScoreSource category_name : typing.Optional[str] reason : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : typing.Optional[str] value_by_author : typing.Optional[typing.Dict[str, ValueEntry]] 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.traces.add_trace_feedback_score(id='id', name='name', value=1.1, source="ui", ) rFrGrHrCrDr1r2r3r4rEr5r#add_trace_feedback_scorer<r%r0rFrGrHrCrDr1r2r3r4rEr5r>s r&rLz%TracesClient.add_trace_feedback_scoresPp$$== '!+!+++>  ~~r(r5tracescT|jj||}|jS)ai Create traces Parameters ---------- traces : typing.Sequence[TraceWrite] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import TraceWrite import datetime client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.create_traces(traces=[TraceWrite(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), )], ) rOr5r# create_tracesr<r%rOr5r>s r&rSzTracesClient.create_tracess*2$$22&Ra2b ~~r( merge_tagsr5idsupdaterVcX|jj||||}|jS)a Update multiple traces Parameters ---------- ids : typing.Sequence[str] List of trace IDs to update (max 1000) update : TraceUpdate merge_tags : typing.Optional[bool] If true, merge tags with existing tags instead of replacing them. Default: false request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import TraceUpdate client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.batch_update_traces(ids=['ids'], update=TraceUpdate(), ) rWrXrVr5r#batch_update_tracesr<r%rWrXrVr5r>s r&r\z TracesClient.batch_update_tracess5F$$88Fz?9 ~~r(cX|jj||||}|jS)a  Update multiple threads Parameters ---------- ids : typing.Sequence[str] List of thread model IDs to update (max 1000) update : TraceThreadUpdate merge_tags : typing.Optional[bool] If true, merge tags with existing tags instead of replacing them. Default: false request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import TraceThreadUpdate client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.batch_update_threads(ids=['ids'], update=TraceThreadUpdate(), ) rZr#batch_update_threadsr<r]s r&r`z!TracesClient.batch_update_threads-s5F$$99Fz?: ~~r( project_name project_id thread_id thread_idsr5rbrcrdrecZ|jj|||||}|jS)a Close one or multiple trace threads. Supports both single thread_id and multiple thread_ids for batch operations. Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] thread_id : typing.Optional[str] thread_ids : typing.Optional[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.traces.close_trace_thread() rar#close_trace_threadr<r%rbrcrdrer5r>s r&rhzTracesClient.close_trace_threadUs;F$$77%!!+ 8 ~~r( pagesizerbrcfilterstruncatestrip_attachmentssortingexcludesearch from_timeto_timer5rkrlrmrnrorprqrrrsrtc j|jj||||||||| | | | |  }|jS)a Get traces by project_name or project_id Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[str] truncate : typing.Optional[bool] strip_attachments : typing.Optional[bool] sorting : typing.Optional[str] exclude : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TracePagePublic Trace resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_traces_by_project() rjr#get_traces_by_projectr<r%rkrlrbrcrmrnrorprqrrrsrtr5r>s r&rwz"TracesClient.get_traces_by_projectsSx$$::%!/+; ~~r( r0rbrFend_timeinputoutputmetadatatags error_infor2ttftrdr5 start_timerzr{r|r}r~rrcl|jj||||||||| | | | | |}|jS)a Get trace Parameters ---------- start_time : dt.datetime id : typing.Optional[str] project_name : typing.Optional[str] If null, the default project is used name : typing.Optional[str] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListStringWrite] output : typing.Optional[JsonListStringWrite] metadata : typing.Optional[JsonListStringWrite] tags : typing.Optional[typing.Sequence[str]] error_info : typing.Optional[ErrorInfoWrite] last_updated_at : typing.Optional[dt.datetime] ttft : typing.Optional[float] Time to first token in milliseconds thread_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi import datetime client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.create_trace(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), ) rr0rbrFrzr{r|r}r~rr2rrdr5r# create_tracer<r%rr0rbrFrzr{r|r}r~rr2rrdr5r>s r&rzTracesClient.create_tracesVB$$11!%!++2 ~~r(ror5cV|jj|||}|jS)a Get trace by id Parameters ---------- id : str strip_attachments : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TracePublic Trace resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_by_id(id='id', ) rr#get_trace_by_idr<r%r0ror5r>s r&rzTracesClient.get_trace_by_id!s3<$$44 "3_5 ~~r(cT|jj||}|jS)a Delete trace 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.traces.delete_trace_by_id(id='id', ) rNr#delete_trace_by_idr<r%r0r5r>s r&rzTracesClient.delete_trace_by_idDs)*$$77O7\ ~~r(rbrcrFrzr{r|r}r~ tags_to_addtags_to_removerrdrr5rrcn|jj||||||||| | | | | ||}|jS)a Update trace by id Parameters ---------- id : str project_name : typing.Optional[str] If null and project_id not specified, Default Project is assumed project_id : typing.Optional[str] If null and project_name not specified, Default Project is assumed name : typing.Optional[str] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListString] output : typing.Optional[JsonListString] metadata : typing.Optional[JsonListString] tags : typing.Optional[typing.Sequence[str]] Tags tags_to_add : typing.Optional[typing.Sequence[str]] Tags to add tags_to_remove : typing.Optional[typing.Sequence[str]] Tags to remove error_info : typing.Optional[ErrorInfo] thread_id : typing.Optional[str] ttft : typing.Optional[float] 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.traces.update_trace(id='id', ) rr# update_tracer<r%r0rbrcrFrzr{r|r}r~rrrrdrr5r>s r&rzTracesClient.update_trace\sYL$$11 %!#)!+2 "~~r(cT|jj||}|jS)a Delete thread comments 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.traces.delete_thread_comments(ids=['ids'], ) rWr5r#delete_thread_commentsr<r%rWr5r>s r&rz#TracesClient.delete_thread_commentss*.$$;;Ud;e ~~r(authorr5namesrcZ|jj|||||}|jS)a Delete thread feedback scores Parameters ---------- project_name : str thread_id : str names : typing.Sequence[str] author : 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.traces.delete_thread_feedback_scores(project_name='project_name', thread_id='thread_id', names=['names'], ) rbrdrrr5r#delete_thread_feedback_scoresr<r%rbrdrrr5r>s r&rz*TracesClient.delete_thread_feedback_scoress:F$$BB%%PVhwC ~~r(cT|jj||}|jS)a Delete trace comments 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.traces.delete_trace_comments(ids=['ids'], ) rr#delete_trace_commentsr<rs r&rz"TracesClient.delete_trace_commentss*.$$::sTc:d ~~r(cX|jj||||}|jS)a Delete trace feedback score Parameters ---------- id : str name : str author : 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.traces.delete_trace_feedback_score(id='id', name='name', ) rFrr5r#delete_trace_feedback_scorer<r%r0rFrr5r>s r&rz(TracesClient.delete_trace_feedback_scores6@$$@@ T&/A ~~r(rbrcr5cX|jj||||}|jS)a Delete trace threads Parameters ---------- thread_ids : typing.Sequence[str] project_name : typing.Optional[str] If null, project_id must be provided project_id : typing.Optional[str] If null, project_name must be provided 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.traces.delete_trace_threads(thread_ids=['thread_ids'], ) rerbrcr5r#delete_trace_threadsr<r%rerbrcr5r>s r&rz!TracesClient.delete_trace_threads6s6D$$99! et: ~~r(cT|jj||}|jS)a Delete traces 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.traces.delete_traces(ids=['ids'], ) rr# delete_tracesr<rs r&rzTracesClient.delete_traces]s).$$22sO2\ ~~r(rcr5cT|jj||}|jS)a Find Feedback Score names Parameters ---------- project_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNamesPublic Feedback Scores resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.find_feedback_score_names2() rr#find_feedback_score_names2r<r%rcr5r>s r&rz'TracesClient.find_feedback_score_names2ws*0$$??:gv?w ~~r(cT|jj||}|jS)aD Find Trace Threads Feedback Score names Parameters ---------- project_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNamesPublic Find Trace Threads Feedback Score names Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.find_trace_threads_feedback_score_names() rr#'find_trace_threads_feedback_score_namesr<rs r&rz4TracesClient.find_trace_threads_feedback_score_namess10$$LL!?M ~~r(rcrbrmrrrsrtr5c ^|jj|||||||}|jS)a Get trace stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] filters : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsPublic Trace stats resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_stats() rr#get_trace_statsr< r%rcrbrmrrrsrtr5r>s r&rzTracesClient.get_trace_statssAT$$44!%+5 ~~r( comment_idcV|jj|||}|jS)a( Get thread comment Parameters ---------- thread_id : str comment_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Comment Comment resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_thread_comment(thread_id='threadId', comment_id='commentId', ) rNr#get_thread_commentr<r%rdrr5r>s r&rzTracesClient.get_thread_comments,4$$77 :_n7o ~~r(c ^|jj|||||||}|jS)a Get trace thread stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] filters : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsPublic Trace thread stats resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_thread_stats() rr#get_trace_thread_statsr<rs r&rz#TracesClient.get_trace_thread_statssAT$$;;!%+< ~~r(trace_idcV|jj|||}|jS)a# Get trace comment Parameters ---------- trace_id : str comment_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Comment Comment resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_comment(trace_id='traceId', comment_id='commentId', ) rNr#get_trace_commentr<r%rrr5r>s r&rzTracesClient.get_trace_comment6s,4$$66x]l6m ~~r(rbrcrnr5cZ|jj|||||}|jS)a~ Get trace thread Parameters ---------- thread_id : str project_name : typing.Optional[str] project_id : typing.Optional[str] truncate : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceThread Trace thread resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_thread(thread_id='thread_id', ) rdrbrcrnr5r#get_trace_threadr<r%rdrbrcrnr5r>s r&rzTracesClient.get_trace_threadSs;H$$55%!+ 6 ~~r( rkrlrbrcrnrormrprrrsrtr5c h|jj||||||||| | | |  } | jS)a Get trace threads Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] truncate : typing.Optional[bool] strip_attachments : typing.Optional[bool] filters : typing.Optional[str] sorting : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceThreadPage Trace threads resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.get_trace_threads() rr#get_trace_threadsr<r%rkrlrbrcrnrormrprrrsrtr5r>s r&rzTracesClient.get_trace_threadssPr$$66%!/+7  ~~r(cZ|jj|||||}|jS)aW Open trace thread Parameters ---------- thread_id : str project_name : typing.Optional[str] project_id : typing.Optional[str] truncate : typing.Optional[bool] 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.traces.open_trace_thread(thread_id='thread_id', ) rr#open_trace_threadr<rs r&rzTracesClient.open_trace_threads;F$$66%!+ 7 ~~r(scorescT|jj||}|jS)a Batch feedback scoring for threads Parameters ---------- scores : typing.Sequence[FeedbackScoreBatchItemThread] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import FeedbackScoreBatchItemThread client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.score_batch_of_threads(scores=[FeedbackScoreBatchItemThread(name='name', value=1.1, source="ui", thread_id='thread_id', )], ) rr5r#score_batch_of_threadsr<r%rr5r>s r&rz#TracesClient.score_batch_of_threadss*6$$;;6[j;k ~~r(cT|jj||}|jS)at Batch feedback scoring for traces Parameters ---------- scores : typing.Sequence[FeedbackScoreBatchItem] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import FeedbackScoreBatchItem client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.score_batch_of_traces(scores=[FeedbackScoreBatchItem(name='name', value=1.1, source="ui", id='id', )], ) rr#score_batch_of_tracesr<rs r&rz"TracesClient.score_batch_of_tracess*6$$::&Zi:j ~~r( rbrcrmlast_retrieved_thread_model_idlimitrnrorsrtr5rrc #K|jj||||||||| |  5} | jEd{dddy7 #1swYyxYww)a Search trace threads Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[typing.Sequence[TraceThreadFilter]] last_retrieved_thread_model_id : typing.Optional[str] limit : typing.Optional[int] Max number of trace thread to be streamed truncate : typing.Optional[bool] Truncate input, output and metadata to slim payloads strip_attachments : typing.Optional[bool] If true, returns attachment references like [file.png]; if false, downloads and reinjects stripped attachments from_time : typing.Optional[dt.datetime] Filter trace threads created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter trace threads created up to this time (ISO-8601 format). If not provided, defaults to current time. Must be after 'from_time'. request_options : typing.Optional[RequestOptions] Request-specific configuration. You can pass in configuration such as `chunk_size`, and more to customize the request and response. Returns ------- typing.Iterator[bytes] Trace threads stream or error during process Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.search_trace_threads() rNr#search_trace_threadsr<) r%rbrcrmrrrnrorsrtr5rs r&rz!TracesClient.search_trace_threads1slp   2 2%!+I/+3  vv         +&AAAA AAA A rbrcrmlast_retrieved_idrrnrorsrtr5rc #K|jj||||||||| |  5} | jEd{dddy7 #1swYyxYww)a Search traces Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[typing.Sequence[TraceFilterPublic]] last_retrieved_id : typing.Optional[str] limit : typing.Optional[int] Max number of traces to be streamed truncate : typing.Optional[bool] Truncate input, output and metadata to slim payloads strip_attachments : typing.Optional[bool] If true, returns attachment references like [file.png]; if false, downloads and reinjects stripped attachments from_time : typing.Optional[dt.datetime] Filter traces created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter traces created up to this time (ISO-8601 format). If not provided, defaults to current time. Must be after 'from_time'. request_options : typing.Optional[RequestOptions] Request-specific configuration. You can pass in configuration such as `chunk_size`, and more to customize the request and response. Returns ------- typing.Iterator[bytes] Traces stream or error during process Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.traces.search_traces() rNr# search_tracesr<) r%rbrcrmrrrnrorsrtr5rs r&rzTracesClient.search_traceswslp   + +%!//+,  vv         rr~rrr5thread_model_idcZ|jj|||||}|jS)a Update thread Parameters ---------- thread_model_id : str tags : typing.Optional[typing.Sequence[str]] tags_to_add : typing.Optional[typing.Sequence[str]] tags_to_remove : typing.Optional[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.traces.update_thread(thread_model_id='threadModelId', ) rr# update_threadr<r%rr~rrr5r>s r&rzTracesClient.update_threads;F$$22 #)+ 3 ~~r(c `|jj||||||||} | jS)a Update thread comment by id Parameters ---------- comment_id : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.update_thread_comment(comment_id='commentId', text='text', ) r9r#update_thread_commentr< r%rr7r0r1r2r3r4r5r>s r&rz"TracesClient.update_thread_commentsDX$$:: !+!++;  ~~r(c `|jj||||||||} | jS)a Update trace comment by id Parameters ---------- comment_id : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.update_trace_comment(comment_id='commentId', text='text', ) r9r#update_trace_commentr<rs r&rz!TracesClient.update_trace_comment!sDX$$99 !+!++:  ~~r()L__name__ __module__ __qualname__rr'propertyrr-OMITstrtypingOptionaldtdatetimerr;rAfloatr DictrrLSequencerrSrboolr\rr`rhintrrwrr rrrrrrrrrrrrrr rrrrrrrrrrrrrr rr rrIteratorbytesrrrrrrr(r&rr"sTJ*;J ?  $(378<+/04;?6 6 6 OOC 6 OOBKK0 6 56OOC(6 -6 86 6z$(378<+/04;?6 6 6 OOC 6 OOBKK0 6 56OOC(6 -6 86 6~/3'+378<+/04IM;?F F F  F $ Fs+F$FOOBKK0F 5FOOC(F -F S*_)EFF 8F FRjn4GMWeGf B-1;? &__S !& & OOD) &  8 & &Z-1;? &__S !&" & OOD) &  8 & &V.2+/*.<@;?*ooc**OOC( * ??3' * OOFOOC$89 * 8* *^&*%)-1+/(,*.37(,(,'+2604;?Kooc"Kooc" K ooc* K OOC( K%K//$'K"??40K%K%K$K??2;;/K-K 8K !Kb$(-1%)156:7;9=6:6:8<'+*.;?!QKKQ OOC Q ooc* Q ooc" Q//"++.Q23Q 34Q//"56Qoofooc23QOON3Q 5Qooe$Q??3'Q  8!Q" #Qn48;? ! !"??40 !  8 !  !FaeSfoon>]im8.2+/%)151526486:=A@D15*.'+;?#W Wooc* W OOC( W ooc" W//"++.W~.W/W//.1Woofooc23W__V__S%9:W(<=WOOI.W??3'W ooe$!W" 8#W$ %Wt`dooc*=C__^=\ @(,;?&& & s# & $ & 8& &R`dooc*=C__^=\ >(,;? # # # $ #  8 # #R.2+/;? %OOC(%ooc* % OOC( %  8 % %P`dooc*=C__^=\ 659mq#__S1KQ??[iKj !859mq#__S1KQ??[iKj !@,0-1(,'+2604;?3OOC(3ooc* 3 % 3 $ 3??2;;/3-3 83 3lfj*-CI??SaCb @,0-1(,'+2604;?3OOC(3ooc* 3 % 3 $ 3??2;;/3-3 83 3lei),BH//R`Ba B.2+/*.;?++ooc* + OOC( + //$' + 8+ +`&*%)-1+/*.37(,(,'+2604;?Gooc"Gooc" G ooc* G OOC( G//$'G"??40G%G%G$G??2;;/G-G 8G GZ.2+/*.;?**ooc* * OOC( * //$' * 8* *`<@  <= 8   D<@  67 8   B.2+/GK?C&**.372604;?Dooc*DOOC( D 1B!CD D )/(< Ds#D//$'D"??40D??2;;/D-D 8D  DR.2+/GK26&**.372604;?Dooc*DOOC( D 1B!CD D "??3/ Ds#D//$'D"??40D??2;;/D-D 8D  DT7;=A@D;?**oofooc23 * __V__S%9: * (<= * 8* *b$(378<+/04;?66 6 OOC 6 OOBKK0 6 56OOC(6 -6 86 6z$(378<+/04;?66 6 OOC 6 OOBKK0 6 56OOC(6 -6 86 6r(rc!leZdZdefdZedefdZeeeeeddde de d e je d e je jd e je jd e je d e je de jeddfdZeeeeeddde de d e je d e je jd e je jd e je d e je de jeddfdZeeeeeeeddd e de dedede je de je d e je jd e je jd e je d e je de je j&e efde jeddfdZddde j,ede jeddfdZeddde j,e dede jede jeddf d Zeddde j,e dede jede jeddf d!Zeeeedd"d#e je d$e je d%e je d&e je j,e de jeddf d'Zdddddddddddddd( d)e jed*e jed#e je d$e je d+e je d,e jed-e jed.e je d/e je d0e je d1e je jd2e je jde jede fd3Z!eeeeeeeeeeeedd4 d5e jd e je d#e je de je d6e je jd7e je"d8e je"d9e je"d:e je j,e d;e je#d e je jdd e d-e jede jede%fd?Z&ddd e de jeddfd@Z'eeeeeeeeeeeeeddAd e d#e je d$e je de je d6e je jd7e je(d8e je(d9e je(d:e je j,e dBe je j,e dCe je j,e d;e je)d%e je dddd^e j,e?de jeddfd_Z@ddd^e j,eAde jeddfd`ZBeeeeeeeeedda d#e je d$e je d+e je j,eCdbe je dce jed,e jed-e jed1e je jd2e je jde jede jeEfddZFeeeeeeeeedde d#e je d$e je d+e je j,eGdfe je dce jed,e jed-e jed1e je jd2e je jde jede jeEfdgZHeeeddhdie d:e je j,e dBe je j,e dCe je j,e de jeddf djZIeeeeedddTe de d e je d e je jd e je jd e je d e je de jeddfdkZJeeeeedddTe de d e je d e je jd e je jd e je d e je de jeddfdlZKy)mAsyncTracesClientr c&t||_yr")rr#r$s r&r'zAsyncTracesClient.__init__[s/~Nr(r)c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawTracesClient r+r,s r&r-z#AsyncTracesClient.with_raw_response^r.r(Nr/r6r7r0r1r2r3r4r5c |K|jj||||||||d{} | jS7w)a7 Add thread comment Parameters ---------- id_ : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.add_thread_comment(id_='id', text='text', ) asyncio.run(main()) r9Nr:r=s r&r;z$AsyncTracesClient.add_thread_commentisR^**== !+!++>   ~~  '<:<c |K|jj||||||||d{} | jS7w)a5 Add trace comment Parameters ---------- id_ : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.add_trace_comment(id_='id', text='text', ) asyncio.run(main()) r9Nr@r=s r&rAz#AsyncTracesClient.add_trace_commentsR^**<< !+!++=   ~~  rrBrFrGrHrCrDrEc K|jj||||||||| | | |  d{} | jS7w)a Add trace feedback score Parameters ---------- id : str name : str value : float source : FeedbackScoreSource category_name : typing.Optional[str] reason : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : typing.Optional[str] value_by_author : typing.Optional[typing.Dict[str, ValueEntry]] 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.traces.add_trace_feedback_score(id='id', name='name', value=1.1, source="ui", ) asyncio.run(main()) rJNrKrMs r&rLz*AsyncTracesClient.add_trace_feedback_scores_v**CC '!+!+++D   ~~  +A>ArNrOcpK|jj||d{}|jS7w)a Create traces Parameters ---------- traces : typing.Sequence[TraceWrite] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import TraceWrite import datetime import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.create_traces(traces=[TraceWrite(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), )], ) asyncio.run(main()) rQNrRrTs r&rSzAsyncTracesClient.create_traces*s78**88Xg8hh ~~i !646rUrWrXrVctK|jj||||d{}|jS7w)a[ Update multiple traces Parameters ---------- ids : typing.Sequence[str] List of trace IDs to update (max 1000) update : TraceUpdate merge_tags : typing.Optional[bool] If true, merge tags with existing tags instead of replacing them. Default: false request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import TraceUpdate import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.batch_update_traces(ids=['ids'], update=TraceUpdate(), ) asyncio.run(main()) rZNr[r]s r&r\z%AsyncTracesClient.batch_update_tracesIsCL**>>Fz??  ~~ #868ctK|jj||||d{}|jS7w)av Update multiple threads Parameters ---------- ids : typing.Sequence[str] List of thread model IDs to update (max 1000) update : TraceThreadUpdate merge_tags : typing.Optional[bool] If true, merge tags with existing tags instead of replacing them. Default: false request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import TraceThreadUpdate import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.batch_update_threads(ids=['ids'], update=TraceThreadUpdate(), ) asyncio.run(main()) rZNr_r]s r&r`z&AsyncTracesClient.batch_update_threadstsDL**??Fz?@  ~~ rrarbrcrdrecvK|jj|||||d{}|jS7w)a- Close one or multiple trace threads. Supports both single thread_id and multiple thread_ids for batch operations. Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] thread_id : typing.Optional[str] thread_ids : typing.Optional[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.traces.close_trace_thread() asyncio.run(main()) raNrgris r&rhz$AsyncTracesClient.close_trace_threadsIL**==%!!+ >  ~~ $979rjrkrlrmrnrorprqrrrsrtc K|jj||||||||| | | | |  d{}|jS7w)aO Get traces by project_name or project_id Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[str] truncate : typing.Optional[bool] strip_attachments : typing.Optional[bool] sorting : typing.Optional[str] exclude : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TracePagePublic Trace 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.traces.get_traces_by_project() asyncio.run(main()) rjNrvrxs r&rwz'AsyncTracesClient.get_traces_by_projectsb~**@@%!/+A  ~~ s,A?Aryrrzr{r|r}r~rrcK|jj||||||||| | | | | |d{}|jS7w)a( Get trace Parameters ---------- start_time : dt.datetime id : typing.Optional[str] project_name : typing.Optional[str] If null, the default project is used name : typing.Optional[str] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListStringWrite] output : typing.Optional[JsonListStringWrite] metadata : typing.Optional[JsonListStringWrite] tags : typing.Optional[typing.Sequence[str]] error_info : typing.Optional[ErrorInfoWrite] last_updated_at : typing.Optional[dt.datetime] ttft : typing.Optional[float] Time to first token in milliseconds thread_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi import datetime import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.create_trace(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), ) asyncio.run(main()) rNrrs r&rzAsyncTracesClient.create_tracesdH**77!%!++8  ~~! s-AAArcrK|jj|||d{}|jS7w)az Get trace by id Parameters ---------- id : str strip_attachments : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TracePublic Trace 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.traces.get_trace_by_id(id='id', ) asyncio.run(main()) rNrrs r&rz!AsyncTracesClient.get_trace_by_idtsBB**:: "3_;  ~~ "757cpK|jj||d{}|jS7w)a+ Delete trace by id Parameters ---------- id : 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.traces.delete_trace_by_id(id='id', ) asyncio.run(main()) rNNrrs r&rz$AsyncTracesClient.delete_trace_by_ids70**==bRa=bb ~~crrrrcK|jj||||||||| | | | | ||d{}|jS7w)a Update trace by id Parameters ---------- id : str project_name : typing.Optional[str] If null and project_id not specified, Default Project is assumed project_id : typing.Optional[str] If null and project_name not specified, Default Project is assumed name : typing.Optional[str] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListString] output : typing.Optional[JsonListString] metadata : typing.Optional[JsonListString] tags : typing.Optional[typing.Sequence[str]] Tags tags_to_add : typing.Optional[typing.Sequence[str]] Tags to add tags_to_remove : typing.Optional[typing.Sequence[str]] Tags to remove error_info : typing.Optional[ErrorInfo] thread_id : typing.Optional[str] ttft : typing.Optional[float] 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.traces.update_trace(id='id', ) asyncio.run(main()) rNrrs r&rzAsyncTracesClient.update_tracesgR**77 %!#)!+8  "~~# s.AAAcpK|jj||d{}|jS7w)aI Delete thread comments 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.traces.delete_thread_comments(ids=['ids'], ) asyncio.run(main()) rNrrs r&rz(AsyncTracesClient.delete_thread_comments s74**AAc[jAkk ~~lrrrrcvK|jj|||||d{}|jS7w)a Delete thread feedback scores Parameters ---------- project_name : str thread_id : str names : typing.Sequence[str] author : 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.traces.delete_thread_feedback_scores(project_name='project_name', thread_id='thread_id', names=['names'], ) asyncio.run(main()) rNrrs r&rz/AsyncTracesClient.delete_thread_feedback_scores. sHL**HH%%PVhwI  ~~ r!cpK|jj||d{}|jS7w)aG Delete trace comments 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.traces.delete_trace_comments(ids=['ids'], ) asyncio.run(main()) rNrrs r&rz'AsyncTracesClient.delete_trace_commentsY s74**@@SZi@jj ~~krctK|jj||||d{}|jS7w)a Delete trace feedback score Parameters ---------- id : str name : str author : 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.traces.delete_trace_feedback_score(id='id', name='name', ) asyncio.run(main()) rNrrs r&rz-AsyncTracesClient.delete_trace_feedback_scorev sDF**FF T&/G  ~~ rrctK|jj||||d{}|jS7w)a Delete trace threads Parameters ---------- thread_ids : typing.Sequence[str] project_name : typing.Optional[str] If null, project_id must be provided project_id : typing.Optional[str] If null, project_name must be provided 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.traces.delete_trace_threads(thread_ids=['thread_ids'], ) asyncio.run(main()) rNrrs r&rz&AsyncTracesClient.delete_trace_threads sEJ**??! et@  ~~ rcpK|jj||d{}|jS7w)a7 Delete traces 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.traces.delete_traces(ids=['ids'], ) asyncio.run(main()) rNrrs r&rzAsyncTracesClient.delete_traces s74**88SRa8bb ~~crrcpK|jj||d{}|jS7w)a Find Feedback Score names Parameters ---------- project_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNamesPublic 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.traces.find_feedback_score_names2() asyncio.run(main()) rNrrs r&rz,AsyncTracesClient.find_feedback_score_names2 s?6**EE!?F  ~~ rcpK|jj||d{}|jS7w)a Find Trace Threads Feedback Score names Parameters ---------- project_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FeedbackScoreNamesPublic Find Trace Threads Feedback Score names 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.traces.find_trace_threads_feedback_score_names() asyncio.run(main()) rNrrs r&rz9AsyncTracesClient.find_trace_threads_feedback_score_names s?6**RR!?S  ~~ rrc zK|jj|||||||d{}|jS7w)aB Get trace stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] filters : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsPublic Trace stats 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.traces.get_trace_stats() asyncio.run(main()) rNrrs r&rz!AsyncTracesClient.get_trace_stats% sOZ**::!%+;  ~~ &;9;rcrK|jj|||d{}|jS7w)a Get thread comment Parameters ---------- thread_id : str comment_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Comment Comment 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.traces.get_thread_comment(thread_id='threadId', comment_id='commentId', ) asyncio.run(main()) rNNrrs r&rz$AsyncTracesClient.get_thread_comment] s9:**==iet=uu ~~vr%c zK|jj|||||||d{}|jS7w)aW Get trace thread stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] filters : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ProjectStatsPublic Trace thread stats 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.traces.get_trace_thread_stats() asyncio.run(main()) rNrrs r&rz(AsyncTracesClient.get_trace_thread_stats} sPZ**AA!%+B  ~~ r1rcrK|jj|||d{}|jS7w)a Get trace comment Parameters ---------- trace_id : str comment_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- Comment Comment 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.traces.get_trace_comment(trace_id='traceId', comment_id='commentId', ) asyncio.run(main()) rNNrrs r&rz#AsyncTracesClient.get_trace_comment s9:**< None: await client.traces.get_trace_thread(thread_id='thread_id', ) asyncio.run(main()) rNrrs r&rz"AsyncTracesClient.get_trace_thread sIN**;;%!+ <  ~~ r!rc K|jj||||||||| | | |  d{} | jS7w)a Get trace threads Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] truncate : typing.Optional[bool] strip_attachments : typing.Optional[bool] filters : typing.Optional[str] sorting : typing.Optional[str] search : typing.Optional[str] from_time : typing.Optional[dt.datetime] to_time : typing.Optional[dt.datetime] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceThreadPage Trace threads 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.traces.get_trace_threads() asyncio.run(main()) rNrrs r&rz#AsyncTracesClient.get_trace_threads s^x**<<%!/+=   ~~  rcvK|jj|||||d{}|jS7w)a Open trace thread Parameters ---------- thread_id : str project_name : typing.Optional[str] project_id : typing.Optional[str] truncate : typing.Optional[bool] 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.traces.open_trace_thread(thread_id='thread_id', ) asyncio.run(main()) rNrrs r&rz#AsyncTracesClient.open_trace_threadQ sIL**<<%!+ =  ~~ r!rcpK|jj||d{}|jS7w)a Batch feedback scoring for threads Parameters ---------- scores : typing.Sequence[FeedbackScoreBatchItemThread] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import FeedbackScoreBatchItemThread import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.score_batch_of_threads(scores=[FeedbackScoreBatchItemThread(name='name', value=1.1, source="ui", thread_id='thread_id', )], ) asyncio.run(main()) rNrrs r&rz(AsyncTracesClient.score_batch_of_threads s7<**AAapAqq ~~rrcpK|jj||d{}|jS7w)a Batch feedback scoring for traces Parameters ---------- scores : typing.Sequence[FeedbackScoreBatchItem] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import FeedbackScoreBatchItem import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.traces.score_batch_of_traces(scores=[FeedbackScoreBatchItem(name='name', value=1.1, source="ui", id='id', )], ) asyncio.run(main()) rNrrs r&rz'AsyncTracesClient.score_batch_of_traces s7<**@@`o@pp ~~qrrrrc K|jj||||||||| |  4d{} | j23d{} | 77 6dddd{7y#1d{7swYyxYww)aZ Search trace threads Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[typing.Sequence[TraceThreadFilter]] last_retrieved_thread_model_id : typing.Optional[str] limit : typing.Optional[int] Max number of trace thread to be streamed truncate : typing.Optional[bool] Truncate input, output and metadata to slim payloads strip_attachments : typing.Optional[bool] If true, returns attachment references like [file.png]; if false, downloads and reinjects stripped attachments from_time : typing.Optional[dt.datetime] Filter trace threads created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter trace threads created up to this time (ISO-8601 format). If not provided, defaults to current time. Must be after 'from_time'. request_options : typing.Optional[RequestOptions] Request-specific configuration. You can pass in configuration such as `chunk_size`, and more to customize the request and response. Returns ------- typing.AsyncIterator[bytes] Trace threads stream or error during process 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.traces.search_trace_threads() asyncio.run(main()) rNr) r%rbrcrmrrrnrorsrtr5rr<s r&rz&AsyncTracesClient.search_trace_threads sv##88%!+I/+9   ff d    f      g*A8A A8 A#AAAA# A8AA# A8AA8#A5)A, *A51A8rrc K|jj||||||||| |  4d{} | j23d{} | 77 6dddd{7y#1d{7swYyxYww)a$ Search traces Parameters ---------- project_name : typing.Optional[str] project_id : typing.Optional[str] filters : typing.Optional[typing.Sequence[TraceFilterPublic]] last_retrieved_id : typing.Optional[str] limit : typing.Optional[int] Max number of traces to be streamed truncate : typing.Optional[bool] Truncate input, output and metadata to slim payloads strip_attachments : typing.Optional[bool] If true, returns attachment references like [file.png]; if false, downloads and reinjects stripped attachments from_time : typing.Optional[dt.datetime] Filter traces created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter traces created up to this time (ISO-8601 format). If not provided, defaults to current time. Must be after 'from_time'. request_options : typing.Optional[RequestOptions] Request-specific configuration. You can pass in configuration such as `chunk_size`, and more to customize the request and response. Returns ------- typing.AsyncIterator[bytes] Traces stream or error during process 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.traces.search_traces() asyncio.run(main()) rNr) r%rbrcrmrrrnrorsrtr5rr<s r&rzAsyncTracesClient.search_traces sv##11%!//+2   ff d    f      r;rrcvK|jj|||||d{}|jS7w)a Update thread Parameters ---------- thread_model_id : str tags : typing.Optional[typing.Sequence[str]] tags_to_add : typing.Optional[typing.Sequence[str]] tags_to_remove : typing.Optional[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.traces.update_thread(thread_model_id='threadModelId', ) asyncio.run(main()) rNrrs r&rzAsyncTracesClient.update_threadV sIL**88 #)+ 9  ~~ r!c |K|jj||||||||d{} | jS7w)aX Update thread comment by id Parameters ---------- comment_id : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.update_thread_comment(comment_id='commentId', text='text', ) asyncio.run(main()) r9Nrrs r&rz'AsyncTracesClient.update_thread_comment sS^**@@ !+!++A   ~~  rc |K|jj||||||||d{} | jS7w)aV Update trace comment by id Parameters ---------- comment_id : str text : str id : typing.Optional[str] created_at : typing.Optional[dt.datetime] last_updated_at : typing.Optional[dt.datetime] created_by : typing.Optional[str] last_updated_by : 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.traces.update_trace_comment(comment_id='commentId', text='text', ) asyncio.run(main()) r9Nrrs r&rz&AsyncTracesClient.update_trace_comment sS^**?? !+!++@   ~~  r)Lrrrrr'rrr-rrrrrr rr;rAr r r rrLr rrSrr r\rr`rhrrrwrr rrrrrrrrrrrrrr rrrrrrrrrrrrrr rr rr AsyncIteratorrrrrrrrrr(r&rrZs\O*<O #7  $(378<+/04;?9 9 9 OOC 9 OOBKK0 9 59OOC(9 -9 89 9@$(378<+/04;?9 9 9 OOC 9 OOBKK0 9 59OOC(9 -9 89 9D/3'+378<+/04IM;?I I I  I $ Is+I$IOOBKK0I 5IOOC(I -I S*_)EFI 8I IXjn4GMWeGf H-1;? )__S !) ) OOD) )  8 ) )`-1;? )__S !)" ) OOD) )  8 ) )\.2+/*.<@;?-ooc*-OOC( - ??3' - OOFOOC$89 - 8- -d&*%)-1+/(,*.37(,(,'+2604;?Nooc"Nooc" N ooc* N OOC( N%N//$'N"??40N%N%N$N??2;;/N-N 8N !Nh$(-1%)156:7;9=6:6:8<'+*.;?!TKKT OOC T ooc* T ooc" T//"++.T23T 34T//"56Toofooc23TOON3T 5Tooe$T??3'T  8!T" #Tt48;? $ $"??40 $  8 $  $Lgk3FOOTbDcos>.2+/%)151526486:=A@D15*.'+;?#Z Zooc* Z OOC( Z ooc" Z//"++.Z~.Z/Z//.1Zoofooc23Z__V__S%9:Z(<=ZOOI.Z??3'Z ooe$!Z" 8#Z$ %Zz`dooc*=C__^=\ F(,;?)) ) s# ) $ ) 8) )X`dooc*=C__^=\ D(,;? & & & $ &  8 & &X.2+/;? (OOC((ooc* ( OOC( (  8 ( (V`dooc*=C__^=\ <59mq#__S1KQ??[iKj !B59mq#__S1KQ??[iKj !F,0-1(,'+2604;?6OOC(6ooc* 6 % 6 $ 6??2;;/6-6 86 6rfj*-CI??SaCb F,0-1(,'+2604;?6OOC(6ooc* 6 % 6 $ 6??2;;/6-6 86 6rei),BH//R`Ba H.2+/*.;?..ooc* . OOC( . //$' . 8. .f&*%)-1+/*.37(,(,'+2604;?Jooc"Jooc" J ooc* J OOC( J//$'J"??40J%J%J$J??2;;/J-J 8J J`.2+/*.;?--ooc* - OOC( - //$' - 8- -f<@  <= 8   J<@  67 8   H.2+/GK?C&**.372604;?Hooc*HOOC( H 1B!CD H )/(< Hs#H//$'H"??40H??2;;/H-H 8H   e $HZ.2+/GK26&**.372604;?Hooc*HOOC( H 1B!CD H "??3/ Hs#H//$'H"??40H??2;;/H-H 8H   e $H\7;=A@D;?--oofooc23 - __V__S%9: - (<= - 8- -h$(378<+/04;?99 9 OOC 9 OOBKK0 9 59OOC(9 -9 89 9@$(378<+/04;?99 9 OOC 9 OOBKK0 9 59OOC(9 -9 89 9r(r)8r rrcore.client_wrapperrrcore.request_optionsr types.commentrtypes.error_infortypes.error_info_writer types.feedback_score_batch_itemr &types.feedback_score_batch_item_threadr !types.feedback_score_names_publicr types.feedback_score_sourcer types.json_list_stringrtypes.json_list_string_writertypes.project_stats_publicrtypes.trace_filter_publicrtypes.trace_page_publicrtypes.trace_publicrtypes.trace_threadrtypes.trace_thread_filterrtypes.trace_thread_pagertypes.trace_thread_updatertypes.trace_updatertypes.trace_writertypes.value_entryr raw_clientrrcastAnyrrrrr(r&rZs G1#(3DQH=3>;95,,959,**=v{{6::s#uup1__r(