j@xddlZddlZddlmZmZddlmZmZddlm Z m Z ddl m Z m Z ddlmZmZddlmZmZdd lmZmZdd lmZmZdd lmZdd lmZmZdd lm Z m!Z!ddl"m#Z#ddl$m%Z%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.m/Z/ddl0m1Z1m2Z2ddl3m4Z4m5Z5ddl6m7Z7m8Z8ddl9m:Z:m;Z;ddlZ>ddl?m@Z@mAZAddlBmCZCmDZDddlEmFZFmGZGddlHmIZImJZJddlKmLZLmMZMddlNmOZOmPZPddlQmRZRmSZSddlTmUZUmVZVdd lWmXZXmYZYdd!lZm[Z[m\Z\dd"l]m^Z^m_Z_dd#l`maZambZbGd$d%ZcGd&d'Zddd(d)ejefd*e#d+effd,Zgy)-N)AgentConfigsClientAsyncAgentConfigsClient) AlertsClientAsyncAlertsClient)AnnotationQueuesClientAsyncAnnotationQueuesClient)AsyncAttachmentsClientAttachmentsClient)#AsyncAutomationRuleEvaluatorsClientAutomationRuleEvaluatorsClient)AsyncChatCompletionsClientChatCompletionsClient)AsyncCheckClient CheckClient)AsyncClientWrapperSyncClientWrapper)RequestOptions)AsyncDashboardsClientDashboardsClient)AsyncDatasetsClientDatasetsClient)OpikApiEnvironment)AsyncExperimentsClientExperimentsClient)AsyncFeedbackDefinitionsClientFeedbackDefinitionsClient)AsyncGuardrailsClientGuardrailsClient)AsyncLlmProviderKeyClientLlmProviderKeyClient)AsyncManualEvaluationClientManualEvaluationClient)AsyncOllamaClient OllamaClient)AsyncOllieStateClientOllieStateClient)!AsyncOpenTelemetryIngestionClientOpenTelemetryIngestionClient)AsyncOptimizationsClientOptimizationsClient)AsyncProjectsClientProjectsClient)AsyncPromptsClient PromptsClient)AsyncRawOpikApi RawOpikApi)AsyncRedirectClientRedirectClient)AsyncRunnersClient RunnersClient)AsyncServiceTogglesClientServiceTogglesClient)AsyncSpansClient SpansClient)AsyncSystemUsageClientSystemUsageClient)AsyncTracesClient TracesClient)AsyncWelcomeWizardClientWelcomeWizardClient)AsyncWorkspacePermissionsClientWorkspacePermissionsClient)AsyncWorkspacesClientWorkspacesClientceZdZdZdej dddddddejededejedejed eje d eje d eje jfd Z ed efdZdddejed ejej$fdZdddejed ejej$fdZy)OpikApia8 Use this class to access the different functions within the SDK. You can instantiate any number of clients with different configuration that will propagate to these functions. Parameters ---------- base_url : typing.Optional[str] The base url to use for requests from the client. environment : OpikApiEnvironment The environment to use for requests from the client. from .environment import OpikApiEnvironment Defaults to OpikApiEnvironment.DEFAULT api_key : typing.Optional[str] workspace_name : typing.Optional[str] timeout : typing.Optional[float] The timeout to be used, in seconds, for requests. By default the timeout is 60 seconds, unless a custom httpx client is used, in which case this default is not enforced. follow_redirects : typing.Optional[bool] Whether the default httpx client follows redirects or not, this is irrelevant if a custom httpx client is passed in. httpx_client : typing.Optional[httpx.Client] The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration. Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) NTbase_url environmentapi_keyworkspace_nametimeoutfollow_redirects httpx_clientrGrHrIrJrKrLrMc 6||n|dn|jj}tt||||||n.|t j ||nt j |||_t|j |_t|j |_ t|j |_ t|j |_t|j |_t#|j |_t'|j |_t+|j |_t/|j |_t3|j |_t7|j |_t;|j |_t?|j |_ tC|j |_"tG|j |_$tK|j |_&tO|j |_(tS|j |_*tW|j |_,t[|j |_.t_|j |_0tc|j |_2tg|j |_4tk|j |_6to|j |_8ts|j |_:tw|j |_<t{|j |_>t|j |_@t|j |_ByN<rGrH)rKrL)rK)rGrIrJrMrK)client_wrapper)CrKreadr _get_base_urlhttpxClient_client_wrapperr1 _raw_clientr; system_usager agent_configsralertsrannotation_queuesr attachmentsrcheckr automation_rule_evaluatorsrchat_completionsr dashboardsrdatasetsr experimentsrfeedback_definitionsr guardrailsr!llm_provider_keyr5runnersr#manual_evaluationr%ollamar' ollie_stater)open_telemetry_ingestionr+ optimizationsr-projectsr/promptsr7service_togglesr9spansr=tracesr?welcome_wizardrAworkspace_permissionsrC workspacesr3redirect selfrGrHrIrJrKrLrM_defaulted_timeouts m/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/client.py__init__zOpikApi.__init__Js*Gl6JP\PdPdPiPi  1"H+N)'& +&8K[\&89& &T5I5IJ-T=Q=QR/t?S?ST"$2F2FG !7tG[G[!\,D+JV\VeVeflfpfpVq*MQ&//.*IU[UdUdekeoeoUpr{rEceZdZdZdej dddddddejededejedejed eje d eje d eje jfd Z ed efdZdddejed ejej$fdZdddejed ejej$fdZy) AsyncOpikApiaG Use this class to access the different functions within the SDK. You can instantiate any number of clients with different configuration that will propagate to these functions. Parameters ---------- base_url : typing.Optional[str] The base url to use for requests from the client. environment : OpikApiEnvironment The environment to use for requests from the client. from .environment import OpikApiEnvironment Defaults to OpikApiEnvironment.DEFAULT api_key : typing.Optional[str] workspace_name : typing.Optional[str] timeout : typing.Optional[float] The timeout to be used, in seconds, for requests. By default the timeout is 60 seconds, unless a custom httpx client is used, in which case this default is not enforced. follow_redirects : typing.Optional[bool] Whether the default httpx client follows redirects or not, this is irrelevant if a custom httpx client is passed in. httpx_client : typing.Optional[httpx.AsyncClient] The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration. Examples -------- from Opik import AsyncOpikApi client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) NTrFrGrHrIrJrKrLrMc 6||n|dn|jj}tt||||||n.|t j ||nt j |||_t|j |_t|j |_ t|j |_ t|j |_t|j |_t#|j |_t'|j |_t+|j |_t/|j |_t3|j |_t7|j |_t;|j |_t?|j |_ tC|j |_"tG|j |_$tK|j |_&tO|j |_(tS|j |_*tW|j |_,t[|j |_.t_|j |_0tc|j |_2tg|j |_4tk|j |_6to|j |_8ts|j |_:tw|j |_<t{|j |_>t|j |_@t|j |_ByrO)CrKrSrrTrU AsyncClientrWr0rXr:rYrrZrr[r r\r r]rr^r r_rr`rrarrbrrcrrdrrer rfr4rgr"rhr$rir&rjr(rkr*rlr,rmr.rnr6ror8rpr<rqr>rrr@rsrBrtr2rurvs ryrzzAsyncOpikApi.__init__s*Gl6JP\PdPdPiPi  2"H+N)'& +""+=P`a""+=>& +$:N:NO2$BVBVW4DDXDXY't7K7KL ! None: await client.is_alive() asyncio.run(main()) rNrrs ryrzAsyncOpikApi.is_alives4***33O3TT ~~U 535cnK|jj|d{}|jS7w)a Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- typing.Optional[typing.Any] default response 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.version() asyncio.run(main()) rNrrs ryrzAsyncOpikApi.version4s4***22?2SS ~~Tr)rrrrrrrrrrrrUrrzrr0rrrrrrr{ryrrs<F*.*<*D*D(,/3*.26;?6Q//#&6Q( 6Q % 6Q , 6Q'6Q!//$/6Qooe&7&786Qp ?  TX1P\b\k\klrlvlv\w0SW0O[a[j[jkqkuku[vr{r)rGrGrHr|c<||S| |jStd)NzEPlease pass in either base_url or environment to construct the client)value ExceptionrQs ryrTrTMs+     _``r{)hrrUagent_configs.clientrr alerts.clientrrannotation_queues.clientrr attachments.clientr r !automation_rule_evaluators.clientr r chat_completions.clientrr check.clientrrcore.client_wrapperrrcore.request_optionsrdashboards.clientrrdatasets.clientrrrHrexperiments.clientrrfeedback_definitions.clientrrguardrails.clientrrllm_provider_key.clientr r!manual_evaluation.clientr"r# ollama.clientr$r%ollie_state.clientr&r'open_telemetry_ingestion.clientr(r)optimizations.clientr*r+projects.clientr,r-prompts.clientr.r/ raw_clientr0r1redirect.clientr2r3runners.clientr4r5service_toggles.clientr6r7 spans.clientr8r9system_usage.clientr:r; traces.clientr<r=welcome_wizard.clientr>r?workspace_permissions.clientr@rAworkspaces.clientrBrCrErrrrTrr{ryrs M:YIrV7F0F@+IbFTY:GlO@=3@=S7J:PeFLL^RRj7;avs3aI[a`car{