jddlZddlZddlmZmZddlmZddlm 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+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4ejjejldZ7GddZ8Gdd Z9y)!N)AsyncClientWrapperSyncClientWrapper)RequestOptions)Comment) ErrorInfo)ErrorInfoWrite)FeedbackScoreBatchItem)FeedbackScoreNamesPublic)FeedbackScoreSource)JsonListString)JsonListStringWrite)ProjectStatsPublic)SpanFilterPublic)SpanPagePublic) SpanPublic) SpanUpdate)SpanUpdateType) SpanWrite) SpanWriteType) ValueEntry)AsyncRawSpansClientRawSpansClient)"FindFeedbackScoreNames1RequestType)GetSpanStatsRequestType)GetSpansByProjectRequestType)!SpanSearchStreamRequestPublicType.c-eZdZdefdZedefdZeeeeeddde 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 dZdddddddddddddddd d!e jed"e jed#e je d$e je d%e je d&e jed'e je d(e jed)e jed*e je d+e je d,e je d-e je jd.e je jde jedef d/Zeeeeeeeeeeeeeeeeeeedd0d1e jd e je d#e je d%e je d2e je de je d&e jed3e je jd4e je d5e je d6e je d7e je d8e je d9e je j*e d:e je j$e efd;e je!d e je jde jede jeddf,d?Z"ddd@d e d)e jede jede#fdAZ$ddd e de jeddfdBZ%eeeeeeeeeeeeeeeeeeddCd e d%e d#e je d$e je d2e je de je d&e je&d3e je jd4e je'd5e je'd6e je'd7e je d8e je d9e je j*e dDe je j*e dEe je j*e d:e je j$e efde jede jeddf,dFZ)ddde j*e de jeddfdGZ*eddHd e de dIe je de jeddf dJZ+ddddKd$e je d&e je,de jede-fdLZ.dddMe dNe de jede/fdOZ0ddddddddddP d$e je d#e je d%e je d&e je1d'e je d,e je d-e je jd.e je jde jede2fdQZ3dddRe j*e4de jeddfdSZ5eeeeeeeeeeddT d%e je d#e je d$e je d&e je6d'e je j*e7dUe jedVe je d(e jed-e je jd.e je jde jede jpe9fdWZ:eeeeedddNe de d e je d e je jd e je jd e je d e je de jeddfdXZ;y)Y SpansClientclient_wrapperc&t||_yN)r!)r _raw_clientselfr!s s/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/spans/client.py__init__zSpansClient.__init__$s)Hreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawSpansClient r$r&s r'with_raw_responsezSpansClient.with_raw_response'r)Nid created_atlast_updated_at created_bylast_updated_byrequest_optionsid_textr1r2r3r4r5r6c `|jj||||||||} | jS)a Add span 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.spans.add_span_comment(id_='id', text='text', ) r8r1r2r3r4r5r6r$add_span_commentdata r&r7r8r1r2r3r4r5r6 _responses r'r<zSpansClient.add_span_comment2sDX$$55 !+!++6  ~~r) category_namereasonr2r3r4r5value_by_authorr6namevaluesourcerArBrCc h|jj||||||||| | | |  } | jS)a Add span 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.spans.add_span_feedback_score(id='id', name='name', value=1.1, source="ui", ) rDrErFrArBr2r3r4r5rCr6r$add_span_feedback_scorer=r&r1rDrErFrArBr2r3r4r5rCr6r?s r'rJz#SpansClient.add_span_feedback_scorejsPp$$<< '!+!+++=  ~~r)r6spanscT|jj||}|jS)aa Create spans Parameters ---------- spans : typing.Sequence[SpanWrite] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import SpanWrite import datetime client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.create_spans(spans=[SpanWrite(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), )], ) rMr6r$ create_spansr=r&rMr6r?s r'rQzSpansClient.create_spanss)2$$111_ ~~r) merge_tagsr6idsupdaterTcX|jj||||}|jS)a Update multiple spans Parameters ---------- ids : typing.Sequence[str] List of span IDs to update (max 1000) update : SpanUpdate 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 SpanUpdate client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.batch_update_spans(ids=['ids'], update=SpanUpdate(trace_id='trace_id', ), ) rUrVrTr6r$batch_update_spansr=r&rUrVrTr6r?s r'rZzSpansClient.batch_update_spanss5F$$77Fz?8 ~~r)pagesize project_name project_idtrace_idtypefilterstruncatestrip_attachmentssortingexcludesearch from_timeto_timer6r]r^r_r`rarbrcrdrerfrgrhrirjcn|jj||||||||| | | | | ||}|jS)ap Get spans by project_name or project_id and optionally by trace_id and/or type Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] trace_id : typing.Optional[str] type : typing.Optional[GetSpansByProjectRequestType] 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 ------- SpanPagePublic Spans resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.get_spans_by_project() r\r$get_spans_by_projectr=r&r]r^r_r`rarbrcrdrerfrgrhrirjr6r?s r'rmz SpansClient.get_spans_by_projectsYD$$99%!/+: "~~r)r1r_raparent_span_idrDrbend_timeinputoutputmetadatamodelprovidertagsusage error_infor3total_estimated_costtotal_estimated_cost_versionttftr6 start_timerprqrrrsrtrurvrwrxryrzr{r|cz|jj||||||||| | | | | ||||||||}|jS)a Create span Parameters ---------- start_time : dt.datetime id : typing.Optional[str] project_name : typing.Optional[str] If null, the default project is used trace_id : typing.Optional[str] parent_span_id : typing.Optional[str] name : typing.Optional[str] type : typing.Optional[SpanWriteType] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListStringWrite] output : typing.Optional[JsonListStringWrite] metadata : typing.Optional[JsonListStringWrite] model : typing.Optional[str] provider : typing.Optional[str] tags : typing.Optional[typing.Sequence[str]] usage : typing.Optional[typing.Dict[str, int]] error_info : typing.Optional[ErrorInfoWrite] last_updated_at : typing.Optional[dt.datetime] total_estimated_cost : typing.Optional[float] total_estimated_cost_version : typing.Optional[str] ttft : typing.Optional[float] Time to first token in milliseconds 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.spans.create_span(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), ) r}r1r_rarprDrbrqrrrsrtrurvrwrxryr3rzr{r|r6r$ create_spanr=r&r}r1r_rarprDrbrqrrrsrtrurvrwrxryr3rzr{r|r6r?s r'rzSpansClient.create_spanKskl$$00!%)!+!5)E++1 .~~r)rer6cV|jj|||}|jS)a  Get span by id Parameters ---------- id : str strip_attachments : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SpanPublic Span resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.get_span_by_id(id='id', ) rr$get_span_by_idr=r&r1rer6r?s r'rzSpansClient.get_span_by_ids3<$$33 "3_4 ~~r)cT|jj||}|jS)a Delete span 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.spans.delete_span_by_id(id='id', ) rLr$delete_span_by_idr=r&r1r6r?s r'rzSpansClient.delete_span_by_ids)*$$66r?6[ ~~r)r_r`rprDrbrqrrrsrtrurvrw tags_to_addtags_to_removerxrzryr|r6rrcz|jj||||||||| | | | | ||||||||}|jS)a3 Update span by id Parameters ---------- id : str trace_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 parent_span_id : typing.Optional[str] name : typing.Optional[str] type : typing.Optional[SpanUpdateType] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListString] output : typing.Optional[JsonListString] metadata : typing.Optional[JsonListString] model : typing.Optional[str] provider : typing.Optional[str] 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 usage : typing.Optional[typing.Dict[str, int]] total_estimated_cost : typing.Optional[float] error_info : typing.Optional[ErrorInfo] 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.spans.update_span(id='id', trace_id='trace_id', ) rar_r`rprDrbrqrrrsrtrurvrwrrrxrzryr|r6r$ update_spanr=r&r1rar_r`rprDrbrqrrrsrtrurvrwrrrxrzryr|r6r?s r'rzSpansClient.update_spanskp$$00 %!)#)!5!++1 .~~r)cT|jj||}|jS)a Delete span 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.spans.delete_span_comments(ids=['ids'], ) rUr6r$delete_span_commentsr=r&rUr6r?s r'rz SpansClient.delete_span_commentsfs*.$$99cSb9c ~~r)authorr6rcX|jj||||}|jS)a Delete span 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.spans.delete_span_feedback_score(id='id', name='name', ) rDrr6r$delete_span_feedback_scorer=r&r1rDrr6r?s r'rz&SpansClient.delete_span_feedback_scores6@$$?? T&/@ ~~r)r`rbr6cV|jj|||}|jS)a] Find Feedback Score names Parameters ---------- project_id : typing.Optional[str] type : typing.Optional[FindFeedbackScoreNames1RequestType] 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.spans.find_feedback_score_names1() rr$find_feedback_score_names1r=r&r`rbr6r?s r'rz&SpansClient.find_feedback_score_names1s3<$$??!o@ ~~r)span_id comment_idcV|jj|||}|jS)a Get span comment Parameters ---------- span_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.spans.get_span_comment(span_id='spanId', comment_id='commentId', ) rLr$get_span_commentr=r&rrr6r?s r'rzSpansClient.get_span_comments,4$$55gz[j5k ~~r) r`r_rarbrcrhrirjr6c b|jj|||||||||  } | jS)a7 Get span stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] trace_id : typing.Optional[str] type : typing.Optional[GetSpanStatsRequestType] 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 Span stats resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.get_span_stats() rr$get_span_statsr= r&r`r_rarbrcrhrirjr6r?s r'rzSpansClient.get_span_statssG`$$33!%+4  ~~r)scorescT|jj||}|jS)aq Batch feedback scoring for spans 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.spans.score_batch_of_spans(scores=[FeedbackScoreBatchItem(name='name', value=1.1, source="ui", id='id', )], ) rr6r$score_batch_of_spansr=r&rr6r?s r'rz SpansClient.score_batch_of_spans"s*6$$99Yh9i ~~r) rar_r`rbrclimitlast_retrieved_idrdrirjr6rrc #K|jj||||||||| | |  5} | jEd{dddy7 #1swYyxYww)as Search spans Parameters ---------- trace_id : typing.Optional[str] project_name : typing.Optional[str] project_id : typing.Optional[str] type : typing.Optional[SpanSearchStreamRequestPublicType] filters : typing.Optional[typing.Sequence[SpanFilterPublic]] limit : typing.Optional[int] Max number of spans to be streamed last_retrieved_id : typing.Optional[str] truncate : typing.Optional[bool] Truncate image included in either input, output or metadata from_time : typing.Optional[dt.datetime] Filter spans created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter spans 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] Spans stream or error during process Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.spans.search_spans() rNr$ search_spansr=) r&rar_r`rbrcrrrdrirjr6rs r'rzSpansClient.search_spans@sot   * *%!/++  vv         s+'AA AA  AA  AAc `|jj||||||||} | jS)a Update span 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.spans.update_span_comment(comment_id='commentId', text='text', ) r:r$update_span_commentr= r&rr8r1r2r3r4r5r6r?s r'rzSpansClient.update_span_commentsDX$$88 !+!++9  ~~r))<__name__ __module__ __qualname__rr(propertyrr.OMITstrtypingOptionaldtdatetimerr<floatr DictrrJSequencerrQrboolrZintrrrmrrr rrrrrr rrrrrr rrrrrrr rrrIteratorbytesrrr)r'r r #s I*;I >  $(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 FRhl 2EK__UcEd B-1;? &__S !& & OOD) &  8 & &V&*%)-1+/)->B(,*.37(,(,'+2604;?#Sooc"Sooc" S ooc* S OOC( S//#&Soo:;S%S//$'S"??40S%S%S$S??2;;/S -!S" 8#S$ %Sr$(-1)-/3%)/3156:7;9=&*)-6:8<6:8<7;=A'+;?/mKKm OOC m ooc* m //#& m,mooc"moom,m//"++.m23m 34m//"56ms#m//#&m oofooc23!m"v{{3845#m$OON3%m& 5'm(%ooe4)m*'-ooc&:+m,ooe$-m. 8/m0 1mf48;? ! !"??40 !  8 !  !F`dCV__^=\hl:.2+//3%)0415152648&*)-6:=A@D8<7;15'+;?/o o o ooc* o OOC( o,oooc"ooon-o//"++.o~.o/o//.1os#o//#&o oofooc23!o"__V__S%9:#o$(<=%o&v{{3845'o(%ooe4)o*OOI.+o,ooe$-o. 8/o0 1od`dooc*=C__^=\ >(,;? # # # $ #  8 # #P,0DH;? !OOC(!oo@A !  8 ! " !Hdh(+AGQ_A` @,0-1)-9=(,'+2604;?;OOC(;ooc* ; //#& ; oo56 ;%;$;??2;;/;-; 8; ;B<@  67 8   B*.-1+/CGFJ&*26*.2604;?G//#&Gooc* G OOC( G oo?@ G1A!BCGs#G"??3/G//$'G??2;;/G-G 8G  G\$(378<+/04;?66 6 OOC 6 OOBKK0 6 56OOC(6 -6 86 6r)r c-eZdZdefdZedefdZeeeeeddde 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 dZdddddddddddddddd d!e jed"e jed#e je d$e je d%e je d&e jed'e je d(e jed)e jed*e je d+e je d,e je d-e je jd.e je jde jedef d/Zeeeeeeeeeeeeeeeeeeedd0d1e jd e je d#e je d%e je d2e je de je d&e jed3e je jd4e je d5e je d6e je d7e je d8e je d9e je j*e d:e je j$e efd;e je!d e je jde jede jeddf,d?Z"ddd@d e d)e jede jede#fdAZ$ddd e de jeddfdBZ%eeeeeeeeeeeeeeeeeeddCd e d%e d#e je d$e je d2e je de je d&e je&d3e je jd4e je'd5e je'd6e je'd7e je d8e je d9e je j*e dDe je j*e dEe je j*e d:e je j$e efde jede jeddf,dFZ)ddde j*e de jeddfdGZ*eddHd e de dIe je de jeddf dJZ+ddddKd$e je d&e je,de jede-fdLZ.dddMe dNe de jede/fdOZ0ddddddddddP d$e je d#e je d%e je d&e je1d'e je d,e je d-e je jd.e je jde jede2fdQZ3dddRe j*e4de jeddfdSZ5eeeeeeeeeeddT d%e je d#e je d$e je d&e je6d'e je j*e7dUe jedVe je d(e jed-e je jd.e je jde jede jpe9fdWZ:eeeeedddNe de d e je d e je jd e je jd e je d e je de jeddfdXZ;y)YAsyncSpansClientr!c&t||_yr#)rr$r%s r'r(zAsyncSpansClient.__init__s.nMr)r*c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawSpansClient r,r-s r'r.z"AsyncSpansClient.with_raw_responser/r)Nr0r7r8r1r2r3r4r5r6c |K|jj||||||||d{} | jS7w)a2 Add span 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.spans.add_span_comment(id_='id', text='text', ) asyncio.run(main()) r:Nr;r>s r'r<z!AsyncSpansClient.add_span_commentsR^**;; !+!++<   ~~  '<:<r@rDrErFrArBrCc K|jj||||||||| | | |  d{} | jS7w)a Add span 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.spans.add_span_feedback_score(id='id', name='name', value=1.1, source="ui", ) asyncio.run(main()) rHNrIrKs r'rJz(AsyncSpansClient.add_span_feedback_score s_v**BB '!+!+++C   ~~  s+A>ArLrMcpK|jj||d{}|jS7w)a Create spans Parameters ---------- spans : typing.Sequence[SpanWrite] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import SpanWrite import datetime import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.spans.create_spans(spans=[SpanWrite(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), )], ) asyncio.run(main()) rONrPrRs r'rQzAsyncSpansClient.create_spansWs78**77eUd7ee ~~f !646rSrUrVrTctK|jj||||d{}|jS7w)ai Update multiple spans Parameters ---------- ids : typing.Sequence[str] List of span IDs to update (max 1000) update : SpanUpdate 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 SpanUpdate import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.spans.batch_update_spans(ids=['ids'], update=SpanUpdate(trace_id='trace_id', ), ) asyncio.run(main()) rXNrYr[s r'rZz#AsyncSpansClient.batch_update_spansvsCL**==Fz?>  ~~ #868r\r]r^r_r`rarbrcrdrerfrgrhrirjcK|jj||||||||| | | | | ||d{}|jS7w)a Get spans by project_name or project_id and optionally by trace_id and/or type Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] project_name : typing.Optional[str] project_id : typing.Optional[str] trace_id : typing.Optional[str] type : typing.Optional[GetSpansByProjectRequestType] 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 ------- SpanPagePublic Spans 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.spans.get_spans_by_project() asyncio.run(main()) r\Nrlrns r'rmz%AsyncSpansClient.get_spans_by_projectshJ**??%!/+@  "~~# s.AAAror}rprqrrrsrtrurvrwrxryrzr{r|cK|jj||||||||| | | | | ||||||||d{}|jS7w)a Create span Parameters ---------- start_time : dt.datetime id : typing.Optional[str] project_name : typing.Optional[str] If null, the default project is used trace_id : typing.Optional[str] parent_span_id : typing.Optional[str] name : typing.Optional[str] type : typing.Optional[SpanWriteType] end_time : typing.Optional[dt.datetime] input : typing.Optional[JsonListStringWrite] output : typing.Optional[JsonListStringWrite] metadata : typing.Optional[JsonListStringWrite] model : typing.Optional[str] provider : typing.Optional[str] tags : typing.Optional[typing.Sequence[str]] usage : typing.Optional[typing.Dict[str, int]] error_info : typing.Optional[ErrorInfoWrite] last_updated_at : typing.Optional[dt.datetime] total_estimated_cost : typing.Optional[float] total_estimated_cost_version : typing.Optional[str] ttft : typing.Optional[float] Time to first token in milliseconds 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.spans.create_span(start_time=datetime.datetime.fromisoformat("2024-01-15 09:30:00+00:00", ), ) asyncio.run(main()) rNrrs r'rzAsyncSpansClient.create_spansyr**66!%)!+!5)E++7  .~~/ 4A AA rcrK|jj|||d{}|jS7w)au Get span by id Parameters ---------- id : str strip_attachments : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SpanPublic Span 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.spans.get_span_by_id(id='id', ) asyncio.run(main()) rNrrs r'rzAsyncSpansClient.get_span_by_idksBB**99 "3_:  ~~ "757cpK|jj||d{}|jS7w)a( Delete span 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.spans.delete_span_by_id(id='id', ) asyncio.run(main()) rLNrrs r'rz"AsyncSpansClient.delete_span_by_ids70**< None: await client.spans.update_span(id='id', trace_id='trace_id', ) asyncio.run(main()) rNrrs r'rzAsyncSpansClient.update_spansyv**66 %!)#)!5!++7  .~~/ rcpK|jj||d{}|jS7w)aD Delete span 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.spans.delete_span_comments(ids=['ids'], ) asyncio.run(main()) rNrrs r'rz%AsyncSpansClient.delete_span_comments s74**??CYh?ii ~~jrrrctK|jj||||d{}|jS7w)a Delete span 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.spans.delete_span_feedback_score(id='id', name='name', ) asyncio.run(main()) rNrrs r'rz+AsyncSpansClient.delete_span_feedback_score=sDF**EE T&/F  ~~ rrcrK|jj|||d{}|jS7w)a Find Feedback Score names Parameters ---------- project_id : typing.Optional[str] type : typing.Optional[FindFeedbackScoreNames1RequestType] 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.spans.find_feedback_score_names1() asyncio.run(main()) rNrrs r'rz+AsyncSpansClient.find_feedback_score_names1esBB**EE!oF  ~~ rrrcrK|jj|||d{}|jS7w)a Get span comment Parameters ---------- span_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.spans.get_span_comment(span_id='spanId', comment_id='commentId', ) asyncio.run(main()) rLNrrs r'rz!AsyncSpansClient.get_span_comments9:**;;GZap;qq ~~rrrc ~K|jj|||||||||  d{} | jS7w)a Get span stats Parameters ---------- project_id : typing.Optional[str] project_name : typing.Optional[str] trace_id : typing.Optional[str] type : typing.Optional[GetSpanStatsRequestType] 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 Span 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.spans.get_span_stats() asyncio.run(main()) rNrrs r'rzAsyncSpansClient.get_span_statssUf**99!%+:   ~~  s (=;=rcpK|jj||d{}|jS7w)a Batch feedback scoring for spans 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.spans.score_batch_of_spans(scores=[FeedbackScoreBatchItem(name='name', value=1.1, source="ui", id='id', )], ) asyncio.run(main()) rNrrs r'rz%AsyncSpansClient.score_batch_of_spanss7<**??v_n?oo ~~prrrrc K|jj||||||||| | |  4d{} | j23d{} | 77 6dddd{7y#1d{7swYyxYww)a Search spans Parameters ---------- trace_id : typing.Optional[str] project_name : typing.Optional[str] project_id : typing.Optional[str] type : typing.Optional[SpanSearchStreamRequestPublicType] filters : typing.Optional[typing.Sequence[SpanFilterPublic]] limit : typing.Optional[int] Max number of spans to be streamed last_retrieved_id : typing.Optional[str] truncate : typing.Optional[bool] Truncate image included in either input, output or metadata from_time : typing.Optional[dt.datetime] Filter spans created from this time (ISO-8601 format). to_time : typing.Optional[dt.datetime] Filter spans 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] Spans 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.spans.search_spans() asyncio.run(main()) rNr)r&rar_r`rbrcrrrdrirjr6rr=s r'rzAsyncSpansClient.search_spans sz##00%!/+1   ff d    f      sg+A9A A9 A$AAAA$ A9AA$ A9A A9$A6*A- +A62A9c |K|jj||||||||d{} | jS7w)aS Update span 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.spans.update_span_comment(comment_id='commentId', text='text', ) asyncio.run(main()) r:Nrrs r'rz$AsyncSpansClient.update_span_commentYsR^**>> !+!++?   ~~  r)B(,*.37(,(,'+2604;?#Vooc"Vooc" V ooc* V OOC( V//#&Voo:;V%V//$'V"??40V%V%V$V??2;;/V -!V" 8#V$ %Vx$(-1)-/3%)/3156:7;9=&*)-6:8<6:8<7;=A'+;?/pKKp OOC p ooc* p //#& p,pooc"poom,p//"++.p23p 34p//"56ps#p//#&p oofooc23!p"v{{3845#p$OON3%p& 5'p(%ooe4)p*'-ooc&:+p,ooe$-p. 8/p0 1pl48;? $ $"??40 $  8 $  $Lfj#6??SaCbnr@.2+//3%)0415152648&*)-6:=A@D8<7;15'+;?/r r r ooc* r OOC( r,rooc"roon-r//"++.r~.r/r//.1rs#r//#&r oofooc23!r"__V__S%9:#r$(<=%r&v{{3845'r(%ooe4)r*OOI.+r,ooe$-r. 8/r0 1rj`dooc*=C__^=\ D(,;? & & & $ &  8 & &V,0DH;? $OOC($oo@A $  8 $ " $Ndh(+AGQ_A` F,0-1)-9=(,'+2604;?>OOC(>ooc* > //#& > oo56 >%>$>??2;;/>-> 8> >H<@  67 8   H*.-1+/CGFJ&*26*.2604;?K//#&Kooc* K OOC( K oo?@ K1A!BCKs#K"??3/K//$'K??2;;/K-K 8K   e $Kd$(378<+/04;?99 9 OOC 9 OOBKK0 9 59OOC(9 -9 89 9r)r):rrrcore.client_wrapperrrcore.request_optionsr types.commentrtypes.error_infortypes.error_info_writer types.feedback_score_batch_itemr !types.feedback_score_names_publicr types.feedback_score_sourcer types.json_list_stringr types.json_list_string_writertypes.project_stats_publicrtypes.span_filter_publicrtypes.span_page_publicrtypes.span_publicrtypes.span_updatertypes.span_update_typertypes.span_writertypes.span_write_typertypes.value_entryr raw_clientrr,types.find_feedback_score_names1request_typer!types.get_span_stats_request_typer'types.get_spans_by_project_request_typer,types.span_search_stream_request_public_typercastAnyrr rrr)r'rs G1#(3DH=3>;73**3(1*;\FQ[v{{6::s#\\~PPr)