jo1ddlZddlmZmZddlmZddlmZddlm Z ddl m Z m Z ejejd ZGd d ZGd d Zy)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)!ManualEvaluationRequestEntityType)ManualEvaluationResponse)AsyncRawManualEvaluationClientRawManualEvaluationClient.c eZdZdefdZedefdZdddede jed e jed e d e je def d Zdddede jed e jed e d e je def d Zdddede jed e jed e d e je def dZy)ManualEvaluationClientclient_wrapperc&t||_yN)r)r _raw_clientselfrs /Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/manual_evaluation/client.py__init__zManualEvaluationClient.__init__s4NSreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawManualEvaluationClient rrs rwith_raw_responsez(ManualEvaluationClient.with_raw_responserNrequest_options project_id entity_idsrule_ids entity_typercZ|jj|||||}|jS)a Manually trigger evaluation rules on selected spans. Bypasses sampling and enqueues all specified spans for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.manual_evaluation.evaluate_spans(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) rr r!r"rrevaluate_spansdatarrr r!r"r _responses rr&z%ManualEvaluationClient.evaluate_spanss;P$$33!!#+ 4 ~~rcZ|jj|||||}|jS)a Manually trigger evaluation rules on selected threads. Bypasses sampling and enqueues all specified threads for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.manual_evaluation.evaluate_threads(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) r$revaluate_threadsr'r(s rr,z'ManualEvaluationClient.evaluate_threadsOs;P$$55!!#+ 6 ~~rcZ|jj|||||}|jS)a Manually trigger evaluation rules on selected traces. Bypasses sampling and enqueues all specified traces for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.manual_evaluation.evaluate_traces(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) r$revaluate_tracesr'r(s rr/z&ManualEvaluationClient.evaluate_tracess;P$$44!!#+ 5 ~~r)__name__ __module__ __qualname__rrpropertyr rstrtypingSequencerOptionalrrr&r,r/rrr r sUT*;T #<  "<@//OOC( / //#& / 7 / 8/ "/p<@//OOC( / //#& / 7 / 8/ "/p<@//OOC( / //#& / 7 / 8/ "/rr c eZdZdefdZedefdZdddede jed e jed e d e je def d Zdddede jed e jed e d e je def d Zdddede jed e jed e d e je def dZy)AsyncManualEvaluationClientrc&t||_yr)r rrs rrz$AsyncManualEvaluationClient.__init__s9Xrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawManualEvaluationClient rrs rrz-AsyncManualEvaluationClient.with_raw_responserrNrrr r!r"rcvK|jj|||||d{}|jS7w)a Manually trigger evaluation rules on selected spans. Bypasses sampling and enqueues all specified spans for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully 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.manual_evaluation.evaluate_spans(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) asyncio.run(main()) r$Nr%r(s rr&z*AsyncManualEvaluationClient.evaluate_spanssIV**99!!#+ :  ~~ $979cvK|jj|||||d{}|jS7w)a Manually trigger evaluation rules on selected threads. Bypasses sampling and enqueues all specified threads for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully 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.manual_evaluation.evaluate_threads(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) asyncio.run(main()) r$Nr+r(s rr,z,AsyncManualEvaluationClient.evaluate_threadssIV**;;!!#+ <  ~~ r>cvK|jj|||||d{}|jS7w)a Manually trigger evaluation rules on selected traces. Bypasses sampling and enqueues all specified traces for evaluation. Parameters ---------- project_id : str Project ID entity_ids : typing.Sequence[str] List of entity IDs (trace IDs or thread IDs) to evaluate rule_ids : typing.Sequence[str] List of automation rule IDs to apply entity_type : ManualEvaluationRequestEntityType Type of entity to evaluate (trace or thread) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ManualEvaluationResponse Accepted - Evaluation request queued successfully 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.manual_evaluation.evaluate_traces(project_id='550e8400-e29b-41d4-a716-446655440000', entity_ids=['550e8400-e29b-41d4-a716-446655440000', '550e8400-e29b-41d4-a716-446655440001'], rule_ids=['660e8400-e29b-41d4-a716-446655440000'], entity_type="trace", ) asyncio.run(main()) r$Nr.r(s rr/z+AsyncManualEvaluationClient.evaluate_traces)sIV**::!!#+ ;  ~~ r>)r0r1r2rrr3r rr4r5r6rr7rrr&r,r/r8rrr:r:sUY*<Y #A  "<@22OOC( 2 //#& 2 7 2 82 "2v<@22OOC( 2 //#& 2 7 2 82 "2v<@22OOC( 2 //#& 2 7 2 82 "2rr:)r5core.client_wrapperrrcore.request_optionsr+types.manual_evaluation_request_entity_typer types.manual_evaluation_responser raw_clientr r castAnyOMITr r:r8rrrIsJG1[GQv{{6::s#``Fiir