j~ddlZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddl m!Z!ddl"m#Z#ddl$m%Z%ddl&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ej^ej`dZ1GddZ2GddZ3y)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)#ExperimentGroupAggregationsResponse)ExperimentGroupResponse)ExperimentItem)3ExperimentItemBulkRecordExperimentItemBulkWriteView)ExperimentItemPublic)ExperimentPagePublic)ExperimentPublic)ExperimentScore)ExperimentScoreWrite)ExperimentUpdate)ExperimentUpdateStatus)ExperimentUpdateType)FeedbackScoreNamesPublic)JsonListStringWrite)JsonNode)PromptVersionLinkWrite)AsyncRawExperimentsClientRawExperimentsClient)ExperimentWriteEvaluationMethod)ExperimentWriteStatus)ExperimentWriteType.c# eZdZdefdZedefdZeddde je de d e jed e jeddf d Zdddddddddddddddd d e jede jede je de je de je de je de jede je de je de jede je de je de je de jed e jedef dZeeeeeeeeeeeeeeeddde je de je de je de je de je d e jed!e je je d"e jed#e jede je d$e jed%e je jed&e jed'e je jed(e je d e jeddf"d)Zdd*d+e jed e jeddfd,Zdd*de je d e jeddfd-Zdd*de je d e jeddfd.Zedd/d0e de d1e jed2e je d e jeddf d3Z ddd4de je d e jede!fd5Z"dddddddd6d7e je de je de je de je de jede je d e jede#fd8Z$dddddddd6d7e je de je de je de je de jede je d e jede%fd9Z&dd*de je d e jeddfd:Z'dd*de d e jede(fd;Z)eeeeeeeedd< de de je d e je*d!e je je d=e je je d>e je je d"e je+d$e je,d%e je je-d e jeddfd?Z.dd*de d e jede/fd@Z0eeeddAd0e dBe jedCe je dDe jed e jede jbe2f dEZ3eeddFde dBe jedCe je d e jede jbe2f dGZ4y)HExperimentsClientclient_wrapperc&t||_yN)r)r _raw_clientselfrs y/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/experiments/client.py__init__zExperimentsClient.__init__#s/~Nreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawExperimentsClient r"r$s r%with_raw_responsez#ExperimentsClient.with_raw_response&r'N merge_tagsrequest_optionsidsupdater/r0cX|jj||||}|jS)a Update multiple experiments Parameters ---------- ids : typing.Sequence[str] List of experiment IDs to update (max 1000) update : ExperimentUpdate 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 ExperimentUpdate client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.batch_update_experiments(ids=['ids'], update=ExperimentUpdate(), ) r1r2r/r0r"batch_update_experimentsdatar$r1r2r/r0 _responses r%r6z*ExperimentsClient.batch_update_experiments1s5F$$==Fz?> ~~r'pagesize dataset_idoptimization_idtypesnamedataset_deleted prompt_id project_idproject_deletedsortingfiltersexperiment_ids force_sortingr0r;r<r=r>r?r@rArBrCrDrErFrGrHcn|jj||||||||| | | | | ||}|jS)a. Find experiments Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] dataset_id : typing.Optional[str] optimization_id : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] dataset_deleted : typing.Optional[bool] prompt_id : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] sorting : typing.Optional[str] filters : typing.Optional[str] experiment_ids : typing.Optional[str] force_sorting : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentPagePublic Experiments resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.find_experiments() r:r"find_experimentsr7r$r;r<r=r>r?r@rArBrCrDrErFrGrHr0r9s r%rKz"ExperimentsClient.find_experimentsYsYD$$55!++!+)'+6 "~~r'id dataset_namerC project_namer@metadatatagstypeevaluation_methodr>statusexperiment_scoresprompt_versionprompt_versionsdataset_version_idr0rNrOrPrQrRrSrTrUrVrWrXrYcp|jj||||||||| | | | | |||}|jS)aF Create experiment Parameters ---------- id : typing.Optional[str] dataset_name : typing.Optional[str] project_id : typing.Optional[str] Project ID. Takes precedence over project_name when both are provided. project_name : typing.Optional[str] Project name. Creates project if it doesn't exist. Ignored when project_id is provided. name : typing.Optional[str] metadata : typing.Optional[JsonListStringWrite] tags : typing.Optional[typing.Sequence[str]] type : typing.Optional[ExperimentWriteType] evaluation_method : typing.Optional[ExperimentWriteEvaluationMethod] optimization_id : typing.Optional[str] status : typing.Optional[ExperimentWriteStatus] experiment_scores : typing.Optional[typing.Sequence[ExperimentScoreWrite]] prompt_version : typing.Optional[PromptVersionLinkWrite] prompt_versions : typing.Optional[typing.Sequence[PromptVersionLinkWrite]] dataset_version_id : typing.Optional[str] ID of the dataset version this experiment is linked to. If not provided at creation, experiment will be automatically linked to the latest version. 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.experiments.create_experiment() rMr"create_experimentr7r$rNrOrCrPr@rQrRrSrTr>rUrVrWrXrYr0r9s r%r\z#ExperimentsClient.create_experiments\N$$66%!%/+/)+1+!7 $~~r'r0experiment_itemscT|jj||}|jS)a Create experiment items Parameters ---------- experiment_items : typing.Sequence[ExperimentItem] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import ExperimentItem client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.create_experiment_items(experiment_items=[ExperimentItem(experiment_id='experiment_id', dataset_item_id='dataset_item_id', trace_id='trace_id', )], ) r_r0r"create_experiment_itemsr7r$r_r0r9s r%rcz)ExperimentsClient.create_experiment_items s06$$<<-= ~~r'cT|jj||}|jS)a Delete experiment items 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.experiments.delete_experiment_items(ids=['ids'], ) r1r0r"delete_experiment_itemsr7r$r1r0r9s r%rhz)ExperimentsClient.delete_experiment_items)s*.$$<<Ve<f ~~r'cT|jj||}|jS)a Delete experiments by id 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.experiments.delete_experiments_by_id(ids=['ids'], ) rfr"delete_experiments_by_idr7ris r%rlz*ExperimentsClient.delete_experiments_by_idCs*.$$==#Wf=g ~~r' experiment_idr0experiment_nameitemsrncZ|jj|||||}|jS)a Record experiment items in bulk with traces, spans, and feedback scores. Maximum request size is 4MB. Parameters ---------- experiment_name : str dataset_name : str items : typing.Sequence[ExperimentItemBulkRecordExperimentItemBulkWriteView] experiment_id : typing.Optional[str] Optional experiment ID. If provided, items will be added to the existing experiment and experimentName will be ignored. If not provided or experiment with that ID doesn't exist, a new experiment will be created with the given experimentName request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import ExperimentItemBulkRecordExperimentItemBulkWriteView client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.experiment_items_bulk(experiment_name='experiment_name', dataset_name='dataset_name', items=[ExperimentItemBulkRecordExperimentItemBulkWriteView(dataset_item_id='dataset_item_id', )], ) rorOrprnr0r"experiment_items_bulkr7r$rorOrprnr0r9s r%rtz'ExperimentsClient.experiment_items_bulk]s;J$$::+%'+ ; ~~r'rGr0cT|jj||}|jS)a" Find Feedback Score names Parameters ---------- experiment_ids : 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.experiments.find_feedback_score_names() rvr"find_feedback_score_namesr7r$rGr0r9s r%ryz+ExperimentsClient.find_feedback_score_namess00$$>>)?? ~~r'groupsr?r@rCrDrFr0r|c ^|jj|||||||}|jS)a Find experiments grouped by specified fields Parameters ---------- groups : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentGroupResponse Experiment groups Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.find_experiment_groups() r{r"find_experiment_groupsr7 r$r|r?r@rCrDrFr0r9s r%rz(ExperimentsClient.find_experiment_groupssAT$$;;!++< ~~r'c ^|jj|||||||}|jS)a5 Find experiments grouped by specified fields with aggregation metrics Parameters ---------- groups : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentGroupAggregationsResponse Experiment groups with aggregations Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.find_experiment_groups_aggregations() r{r"#find_experiment_groups_aggregationsr7rs r%rz5ExperimentsClient.find_experiment_groups_aggregationssBT$$HH!++I ~~r'cT|jj||}|jS)a Finish experiments and trigger alert events 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.experiments.finish_experiments(ids=['ids'], ) rfr"finish_experimentsr7ris r%rz$ExperimentsClient.finish_experimentss*.$$77CQ`7a ~~r'cT|jj||}|jS)a Get experiment by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentPublic Experiment resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.get_experiment_by_id(id='id', ) r^r"get_experiment_by_idr7r$rNr0r9s r%rz&ExperimentsClient.get_experiment_by_id,s)0$$99"o9^ ~~r' r@rQrR tags_to_addtags_to_removerSrUrVr0rrc d|jj||||||||| |  } | jS)a Update experiment by id Parameters ---------- id : str name : typing.Optional[str] metadata : typing.Optional[JsonNode] 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 type : typing.Optional[ExperimentUpdateType] status : typing.Optional[ExperimentUpdateStatus] The status of the experiment experiment_scores : typing.Optional[typing.Sequence[ExperimentScore]] 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.experiments.update_experiment(id='id', ) rr"update_experimentr7 r$rNr@rQrRrrrSrUrVr0r9s r%rz#ExperimentsClient.update_experimentGsJl$$66 #)/+7  ~~r'cT|jj||}|jS)a  Get experiment item by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentItemPublic Experiment item resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.experiments.get_experiment_item_by_id(id='id', ) r^r"get_experiment_item_by_idr7rs r%rz+ExperimentsClient.get_experiment_item_by_ids*0$$>>rSb>c ~~r'limitlast_retrieved_idtruncater0rrrc#K|jj|||||5}|jEd{dddy7 #1swYyxYww)a Stream experiment items Parameters ---------- experiment_name : str limit : typing.Optional[int] last_retrieved_id : typing.Optional[str] truncate : typing.Optional[bool] Truncate image included in either input, output or metadata 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] Experiment items stream or error during process rorrrr0Nr"stream_experiment_itemsr7)r$rorrrr0rs r%rz)ExperimentsClient.stream_experiment_itemss\>   5 5+/+ 6 vv       s+!AAAA AAA Arrr0c#K|jj||||5}|jEd{dddy7 #1swYyxYww)a Stream experiments Parameters ---------- name : str limit : typing.Optional[int] last_retrieved_id : typing.Optional[str] 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] Experiments stream or error during process r@rrr0Nr"stream_experimentsr7)r$r@rrr0rs r%rz$ExperimentsClient.stream_experimentssV6   0 0U6GYh1 vv       s+ AAAA AAA A)5__name__ __module__ __qualname__rr&propertyrr,OMITtypingSequencestrrOptionalboolrr6intr rKrrrrrrr\r rcrhrlr rtrryrrrrrr rrrrrrr rIteratorbytesrrr'r%rr"sO*;O #7  -1;? &__S !&! & OOD) &  8 & &V&*%)+/04&*%)15*.+/15(,(,/3/3;?#Sooc"Sooc" S OOC( S  - Ss#Sooc"S .S??3'SOOC(S .S%S%S,S t,!S" 8#S$ %Sp$(-1+/-1%)9=6:59NR049=TXBFTX37;?%Y OOC Yooc* Y OOC( Y ooc* Yooc"Y//"56Yoofooc23Yoo12Y"??+JKY -Y 56Y"??6??;O+PQY(>?Y  9O)PQ!Y"#OOC0#Y$ 8%Y& 'Y~<@ !//.9 8   B`dooc*=C__^=\ 6`dooc*=C__^=\ @/3;?,, , RS , s+ , 8, ,^9=qu!'!5OU_mOn !@(,&*%)+/15(,;?3$3s# 3 ooc" 3 OOC( 3 .3%3 83 !3p(,&*%)+/15(,;?3$3s# 3 ooc" 3 OOC( 3 .3%3 83 -3l`dooc*=C__^=\ 6NR+1??>+J >&*.26:=A@D6::>OS;?B Booc" B //(+ B oofooc23 B__V__S%9:B(<=Boo23B 67B"??6???+KLB 8B BJNR+1??>+J >'+26*.;?&&s# & "??3/ & //$' & 8&  &X'+26;? s#  "??3/   8   r'rc# eZdZdefdZedefdZeddde je de d e jed e jeddf d Zdddddddddddddddd d e jede jede je de je de je de je de jede je de je de jede je de je de je de jed e jedef dZeeeeeeeeeeeeeeeddde je de je de je de je de je d e jed!e je je d"e jed#e jede je d$e jed%e je jed&e jed'e je jed(e je d e jeddf"d)Zdd*d+e jed e jeddfd,Zdd*de je d e jeddfd-Zdd*de je d e jeddfd.Zedd/d0e de d1e jed2e je d e jeddf d3Z ddd4de je d e jede!fd5Z"dddddddd6d7e je de je de je de je de jede je d e jede#fd8Z$dddddddd6d7e je de je de je de je de jede je d e jede%fd9Z&dd*de je d e jeddfd:Z'dd*de d e jede(fd;Z)eeeeeeeedd< de de je d e je*d!e je je d=e je je d>e je je d"e je+d$e je,d%e je je-d e jeddfd?Z.dd*de d e jede/fd@Z0eeeddAd0e dBe jedCe je dDe jed e jede jbe2f dEZ3eeddFde dBe jedCe je d e jede jbe2f dGZ4y)HAsyncExperimentsClientrc&t||_yr!)rr"r#s r%r&zAsyncExperimentsClient.__init__s4NSr'r(c|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawExperimentsClient r*r+s r%r,z(AsyncExperimentsClient.with_raw_responser-r'Nr.r1r2r/r0ctK|jj||||d{}|jS7w)a~ Update multiple experiments Parameters ---------- ids : typing.Sequence[str] List of experiment IDs to update (max 1000) update : ExperimentUpdate 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 ExperimentUpdate import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.experiments.batch_update_experiments(ids=['ids'], update=ExperimentUpdate(), ) asyncio.run(main()) r4Nr5r8s r%r6z/AsyncExperimentsClient.batch_update_experimentssDL**CCFz?D  ~~ s #868r:r;r<r=r>r?r@rArBrCrDrErFrGrHcK|jj||||||||| | | | | ||d{}|jS7w)a Find experiments Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] dataset_id : typing.Optional[str] optimization_id : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] dataset_deleted : typing.Optional[bool] prompt_id : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] sorting : typing.Optional[str] filters : typing.Optional[str] experiment_ids : typing.Optional[str] force_sorting : typing.Optional[bool] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentPagePublic Experiments 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.experiments.find_experiments() asyncio.run(main()) r:NrJrLs r%rKz'AsyncExperimentsClient.find_experiments)sgJ**;;!++!+)'+<  "~~# s.AAArMrNrOrPrQrRrSrTrUrVrWrXrYcK|jj||||||||| | | | | |||d{}|jS7w)a Create experiment Parameters ---------- id : typing.Optional[str] dataset_name : typing.Optional[str] project_id : typing.Optional[str] Project ID. Takes precedence over project_name when both are provided. project_name : typing.Optional[str] Project name. Creates project if it doesn't exist. Ignored when project_id is provided. name : typing.Optional[str] metadata : typing.Optional[JsonListStringWrite] tags : typing.Optional[typing.Sequence[str]] type : typing.Optional[ExperimentWriteType] evaluation_method : typing.Optional[ExperimentWriteEvaluationMethod] optimization_id : typing.Optional[str] status : typing.Optional[ExperimentWriteStatus] experiment_scores : typing.Optional[typing.Sequence[ExperimentScoreWrite]] prompt_version : typing.Optional[PromptVersionLinkWrite] prompt_versions : typing.Optional[typing.Sequence[PromptVersionLinkWrite]] dataset_version_id : typing.Optional[str] ID of the dataset version this experiment is linked to. If not provided at creation, experiment will be automatically linked to the latest version. 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.experiments.create_experiment() asyncio.run(main()) rMNr[r]s r%r\z(AsyncExperimentsClient.create_experimentsjT**<<%!%/+/)+1+!=  $~~% s/AAAr^r_cpK|jj||d{}|jS7w)a Create experiment items Parameters ---------- experiment_items : typing.Sequence[ExperimentItem] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import ExperimentItem import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.experiments.create_experiment_items(experiment_items=[ExperimentItem(experiment_id='experiment_id', dataset_item_id='dataset_item_id', trace_id='trace_id', )], ) asyncio.run(main()) raNrbrds r%rcz.AsyncExperimentsClient.create_experiment_itemss?<**BB-C  ~~ !646cpK|jj||d{}|jS7w)aP Delete experiment items 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.experiments.delete_experiment_items(ids=['ids'], ) asyncio.run(main()) rfNrgris r%rhz.AsyncExperimentsClient.delete_experiment_itemss74**BBs\kBll ~~mrcpK|jj||d{}|jS7w)aR Delete experiments by id 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.experiments.delete_experiments_by_id(ids=['ids'], ) asyncio.run(main()) rfNrkris r%rlz/AsyncExperimentsClient.delete_experiments_by_ids74**CC]lCmm ~~nrrmrorprncvK|jj|||||d{}|jS7w)a Record experiment items in bulk with traces, spans, and feedback scores. Maximum request size is 4MB. Parameters ---------- experiment_name : str dataset_name : str items : typing.Sequence[ExperimentItemBulkRecordExperimentItemBulkWriteView] experiment_id : typing.Optional[str] Optional experiment ID. If provided, items will be added to the existing experiment and experimentName will be ignored. If not provided or experiment with that ID doesn't exist, a new experiment will be created with the given experimentName request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import ExperimentItemBulkRecordExperimentItemBulkWriteView import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.experiments.experiment_items_bulk(experiment_name='experiment_name', dataset_name='dataset_name', items=[ExperimentItemBulkRecordExperimentItemBulkWriteView(dataset_item_id='dataset_item_id', )], ) asyncio.run(main()) rrNrsrus r%rtz,AsyncExperimentsClient.experiment_items_bulk<sJP**@@+%'+ A  ~~ s $979rvcpK|jj||d{}|jS7w)a Find Feedback Score names Parameters ---------- experiment_ids : 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.experiments.find_feedback_score_names() asyncio.run(main()) rvNrxrzs r%ryz0AsyncExperimentsClient.find_feedback_score_namesms?6**DD)?E  ~~ rr{r|c zK|jj|||||||d{}|jS7w)aZ Find experiments grouped by specified fields Parameters ---------- groups : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentGroupResponse Experiment groups 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.experiments.find_experiment_groups() asyncio.run(main()) r{Nr~rs r%rz-AsyncExperimentsClient.find_experiment_groupssPZ**AA!++B  ~~ &;9;c zK|jj|||||||d{}|jS7w)a Find experiments grouped by specified fields with aggregation metrics Parameters ---------- groups : typing.Optional[str] types : typing.Optional[str] name : typing.Optional[str] project_id : typing.Optional[str] project_deleted : typing.Optional[bool] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentGroupAggregationsResponse Experiment groups with aggregations 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.experiments.find_experiment_groups_aggregations() asyncio.run(main()) r{Nrrs r%rz:AsyncExperimentsClient.find_experiment_groups_aggregationssPZ**NN!++O  ~~ rcpK|jj||d{}|jS7w)a_ Finish experiments and trigger alert events 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.experiments.finish_experiments(ids=['ids'], ) asyncio.run(main()) rfNrris r%rz)AsyncExperimentsClient.finish_experimentss74**==#Wf=gg ~~hrcpK|jj||d{}|jS7w)a` Get experiment by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentPublic Experiment 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.experiments.get_experiment_by_id(id='id', ) asyncio.run(main()) r^Nrrs r%rz+AsyncExperimentsClient.get_experiment_by_ids76**??Tc?dd ~~errrrc K|jj||||||||| |  d{} | jS7w)af Update experiment by id Parameters ---------- id : str name : typing.Optional[str] metadata : typing.Optional[JsonNode] 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 type : typing.Optional[ExperimentUpdateType] status : typing.Optional[ExperimentUpdateStatus] The status of the experiment experiment_scores : typing.Optional[typing.Sequence[ExperimentScore]] 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.experiments.update_experiment(id='id', ) asyncio.run(main()) rNrrs r%rz(AsyncExperimentsClient.update_experiment8sXr**<< #)/+=   ~~  s )><>cpK|jj||d{}|jS7w)as Get experiment item by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ExperimentItemPublic Experiment item 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.experiments.get_experiment_item_by_id(id='id', ) asyncio.run(main()) r^Nrrs r%rz0AsyncExperimentsClient.get_experiment_item_by_ids76**DDRYhDii ~~jrrrrrcK|jj|||||4d{}|j23d{}|77 6dddd{7y#1d{7swYyxYww)a Stream experiment items Parameters ---------- experiment_name : str limit : typing.Optional[int] last_retrieved_id : typing.Optional[str] truncate : typing.Optional[bool] Truncate image included in either input, output or metadata 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] Experiment items stream or error during process rNr)r$rorrrr0rr7s r%rz.AsyncExperimentsClient.stream_experiment_itemsst>##;;+/+ <  ff d   f     se%A3AA3 AA A A AA3 A  A A3AA3A0$A' %A0,A3rcK|jj||||4d{}|j23d{}|77 6dddd{7y#1d{7swYyxYww)a Stream experiments Parameters ---------- name : str limit : typing.Optional[int] last_retrieved_id : typing.Optional[str] 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] Experiments stream or error during process rNr)r$r@rrr0rr7s r%rz)AsyncExperimentsClient.stream_experimentssn6##66U6GYh7  ff d   f     sd$A2AA2 AA AA AA2A  A A2AA2A/#A& $A/+A2)5rrrrr&rrr,rrrrrrrrr6rr rKrrrrrrr\r rcrhrlr rtrryrrrrrr rrrrrrr r AsyncIteratorrrrrr'r%rrsT*<T #<  -1;? )__S !)! ) OOD) )  8 ) )\&*%)+/04&*%)15*.+/15(,(,/3/3;?#Vooc"Vooc" V OOC( V  - Vs#Vooc"V .V??3'VOOC(V .V%V%V,V t,!V" 8#V$ %Vv$(-1+/-1%)9=6:59NR049=TXBFTX37;?%\ OOC \ooc* \ OOC( \ ooc* \ooc"\//"56\oofooc23\oo12\"??+JK\ -\ 56\"??6??;O+PQ\(>?\  9O)PQ!\"#OOC0#\$ 8%\& '\D<@ !!//.9! 8 !  !H`dooc*=C__^=\ <`dooc*=C__^=\ F/3;?// / RS / s+ / 8/ /d9=qu!'!5OU_mOn !F(,&*%)+/15(,;?6$6s# 6 ooc" 6 OOC( 6 .6%6 86 !6v(,&*%)+/15(,;?6$6s# 6 ooc" 6 OOC( 6 .6%6 86 -6r`dooc*=C__^=\ <NR+1??>+J D&*.26:=A@D6::>OS;?E Eooc" E //(+ E oofooc23 E__V__S%9:E(<=Eoo23E 67E"??6???+KLE 8E EPNR+1??>+J D'+26*.;?''s# ' "??3/ ' //$' ' 8'   e $'Z'+26;? s#  "??3/   8    e $r'r)4rcore.client_wrapperrrcore.request_optionsr,types.experiment_group_aggregations_responsertypes.experiment_group_responsertypes.experiment_itemr Atypes.experiment_item_bulk_record_experiment_item_bulk_write_viewr types.experiment_item_publicr types.experiment_page_publicr types.experiment_publicr types.experiment_scorertypes.experiment_score_writertypes.experiment_updatertypes.experiment_update_statusrtypes.experiment_update_typer!types.feedback_score_names_publicrtypes.json_list_string_writertypes.json_nodertypes.prompt_version_link_writer raw_clientrr(types.experiment_write_evaluation_methodrtypes.experiment_write_statusrtypes.experiment_write_typercastAnyrrrrr'r%rsG1^E2@?64?6C?H>&DGU@<v{{6::s#J J Zv v r'