j+.ddlZddlmZmZddlmZddlmZddlm Z ddl m Z dd l m Z mZGd d ZGd d Zy)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)BiInformationResponse)SpansCountResponse)TraceCountResponse)AsyncRawSystemUsageClientRawSystemUsageClientcNeZdZdefdZedefdZdddeje de fdZ dddeje de fd Z dddeje de fd Zdddeje defd Zdddeje de fd Zdddeje defd Zy)SystemUsageClientclient_wrapperc&t||_yN)r)r _raw_clientselfrs z/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/system_usage/client.py__init__zSystemUsageClient.__init__s/~Nreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawSystemUsageClient rrs rwith_raw_responsez#SystemUsageClient.with_raw_responserNrequest_optionsrcR|jj|}|jS)a Get datasets information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Datasets BiInformationResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_dataset_bi_info() rrget_dataset_bi_infodatarr _responses rr"z%SystemUsageClient.get_dataset_bi_infos'($$888Y ~~rcR|jj|}|jS)a' Get experiments information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Experiments BiInformationResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_experiment_bi_info() rrget_experiment_bi_infor#r$s rr(z(SystemUsageClient.get_experiment_bi_info3s',$$;;O;\ ~~rcR|jj|}|jS)a Get spans information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Spans BiInformationResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_spans_bi_info() rrget_spans_bi_infor#r$s rr+z#SystemUsageClient.get_spans_bi_infoLs'($$666W ~~rcR|jj|}|jS)a Get spans count on previous day for all available workspaces Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SpansCountResponse SpanCountResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_spans_count_for_workspaces() rrget_spans_count_for_workspacesr#r$s rr.z0SystemUsageClient.get_spans_count_for_workspacescs(,$$CCTcCd ~~rcR|jj|}|jS)a Get traces information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Traces BiInformationResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_traces_bi_info() rrget_traces_bi_infor#r$s rr1z$SystemUsageClient.get_traces_bi_info|s'($$777X ~~rcR|jj|}|jS)a Get traces count on previous day for all available workspaces Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceCountResponse TraceCountResponse resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.system_usage.get_traces_count_for_workspaces() rrget_traces_count_for_workspacesr#r$s rr4z1SystemUsageClient.get_traces_count_for_workspacess(,$$DDUdDe ~~r)__name__ __module__ __qualname__rrpropertyr rtypingOptionalrrr"r(r+rr.r1r r4rrrr sO*;O #7  Y]foon6Uav0EI"(//."A 2W[FOON4S_t0EI"(//."A 2X\V__^5T`u0EI"(//."A rrcNeZdZdefdZedefdZdddeje de fdZ dddeje de fd Z dddeje de fd Zdddeje defd Zdddeje de fd Zdddeje defd Zy)AsyncSystemUsageClientrc&t||_yr)r rrs rrzAsyncSystemUsageClient.__init__s4NSrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawSystemUsageClient rrs rrz(AsyncSystemUsageClient.with_raw_responserrNrrcnK|jj|d{}|jS7w)a Get datasets information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Datasets BiInformationResponse 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.system_usage.get_dataset_bi_info() asyncio.run(main()) rNr!r$s rr"z*AsyncSystemUsageClient.get_dataset_bi_infos42**>>>__ ~~` 535cnK|jj|d{}|jS7w)a Get experiments information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Experiments BiInformationResponse 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.system_usage.get_experiment_bi_info() asyncio.run(main()) rNr'r$s rr(z-AsyncSystemUsageClient.get_experiment_bi_infos52**AARaAbb ~~crAcnK|jj|d{}|jS7w)a Get spans information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Spans BiInformationResponse 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.system_usage.get_spans_bi_info() asyncio.run(main()) rNr*r$s rr+z(AsyncSystemUsageClient.get_spans_bi_infos42**<<_<]] ~~^rAcnK|jj|d{}|jS7w)a Get spans count on previous day for all available workspaces Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SpansCountResponse SpanCountResponse 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.system_usage.get_spans_count_for_workspaces() asyncio.run(main()) rNr-r$s rr.z5AsyncSystemUsageClient.get_spans_count_for_workspacess52**IIZiIjj ~~krAcnK|jj|d{}|jS7w)a Get traces information for BI events per user per workspace Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BiInformationResponse Traces BiInformationResponse 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.system_usage.get_traces_bi_info() asyncio.run(main()) rNr0r$s rr1z)AsyncSystemUsageClient.get_traces_bi_info,s42**==o=^^ ~~_rAcnK|jj|d{}|jS7w)a Get traces count on previous day for all available workspaces Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- TraceCountResponse TraceCountResponse 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.system_usage.get_traces_count_for_workspaces() asyncio.run(main()) rNr3r$s rr4z6AsyncSystemUsageClient.get_traces_count_for_workspacesHs52**JJ[jJkk ~~lrA)r5r6r7rrr8r rr9r:rrr"r(r+rr.r1r r4r;rrr=r=s T*<T #<  EI"(//."A :EI"(//."A :EI"(//."A :EI"(//."A :EI"(//."A :EI"(//."A rr=)r9core.client_wrapperrrcore.request_optionsrtypes.bi_information_responsertypes.spans_count_responsertypes.trace_count_responser raw_clientr r rr=r;rrrMs5G1A;;G]]@uur