jMddlZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZd d lmZmZd dlmZej2ej4dZGddZGddZy)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)AlertPagePublic) AlertPublic)AlertTriggerWrite)AlertWriteAlertType)WebhookExamples)WebhookTestResult) WebhookWrite)AsyncRawAlertsClientRawAlertsClient)"GetWebhookExamplesRequestAlertType.c8eZdZdefdZedefdZdddddddeje deje d eje d eje d eje de f d Zeeeeeedd dedeje deje dejedejedejej&e e fdejej(ed eje ddfdZdddej(e d eje ddfdZddde d eje defdZeeeeeedd de dedeje deje dejedejedejej&e e fdejej(ed eje ddfdZddddejed eje defdZeeeeeedd dedeje deje dejedejedejej&e e fdejej(ed eje defdZy) AlertsClientclient_wrapperc&t||_yN)r)r _raw_clientselfrs t/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/rest_api/alerts/client.py__init__zAlertsClient.__init__s*.Ireturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawAlertsClient rrs rwith_raw_responsezAlertsClient.with_raw_responserNpagesizesortingfiltersrequest_optionsr$r%r&r'r(cZ|jj|||||}|jS)aM Find alerts Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] sorting : typing.Optional[str] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AlertPagePublic OK Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.find_alerts() r#r find_alertsdatarr$r%r&r'r( _responses rr+zAlertsClient.find_alerts$s8H$$00D'7Tc1 ~~ridnameenabled alert_typemetadatatriggersr(webhookr0r1r2r3r4r5c `|jj||||||||} | jS)a3 Create alert Parameters ---------- webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import WebhookWrite client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.create_alert(webhook=WebhookWrite(url='url', ), ) r6r0r1r2r3r4r5r(r create_alertr, rr6r0r1r2r3r4r5r(r.s rr:zAlertsClient.create_alertMsDZ$$11!+2  ~~rr(idscT|jj||}|jS)a Delete multiple alerts by their IDs 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.alerts.delete_alert_batch(ids=['ids'], ) r=r(rdelete_alert_batchr,rr=r(r.s rrAzAlertsClient.delete_alert_batchs*.$$77CQ`7a ~~rcT|jj||}|jS)a Get Alert by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AlertPublic Alert resource Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.get_alert_by_id(id='id', ) r<rget_alert_by_idr,rr0r(r.s rrEzAlertsClient.get_alert_by_ids),$$44R4Y ~~rid_c b|jj|||||||||  } | jS)aP Update alert Parameters ---------- id_ : str webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import OpikApi from Opik import WebhookWrite client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.update_alert(id_='id', webhook=WebhookWrite(url='url', ), ) r8r update_alertr, rrGr6r0r1r2r3r4r5r(r.s rrJzAlertsClient.update_alertsG`$$11 !+2  ~~rr3r(cT|jj||}|jS)ab Get webhook payload examples for all alert event types, optionally filtered by alert type Parameters ---------- alert_type : typing.Optional[GetWebhookExamplesRequestAlertType] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- WebhookExamples Webhook examples Examples -------- from Opik import OpikApi client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.get_webhook_examples() rLrget_webhook_examplesr,rr3r(r.s rrOz!AlertsClient.get_webhook_exampless*6$$99Zap9q ~~rc `|jj||||||||} | jS)a_ Test alert webhook Parameters ---------- webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- WebhookTestResult Webhook test Examples -------- from Opik import OpikApi from Opik import WebhookWrite client = OpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) client.alerts.test_webhook(webhook=WebhookWrite(url='url', ), ) r8r test_webhookr,r;s rrSzAlertsClient.test_webhooksD\$$11!+2  ~~r) __name__ __module__ __qualname__rrpropertyrr!typingOptionalintstrrrr+OMITr boolr DictSequencer r:rArrErJrr rOr rSrrrrsJ*;J ?  &*%)(,(,;?'ooc"'ooc" ' % ' % ' 8' 'Z$(%))-;?;?HL;?77 OOC 7 ooc" 7 & 7OO$787//&++c3h"787//&//2C"DE7 87 7t`dooc*=C__^=\ 4^b#6??>;Zfq<$(%))-;?;?HL;?; ; ; OOC ; ooc" ;&;OO$78;//&++c3h"78;//&//2C"DE; 8; ;@KO;? OO$FG 8   D$(%))-;?;?HL;?88 OOC 8 ooc" 8 & 8OO$788//&++c3h"788//&//2C"DE8 88 8rrc8eZdZdefdZedefdZdddddddeje deje d eje d eje d eje de f d Zeeeeeedd dedeje deje dejedejedejej&e e fdejej(ed eje ddfdZdddej(e d eje ddfdZddde d eje defdZeeeeeedd de dedeje deje dejedejedejej&e e fdejej(ed eje ddfdZddddejed eje defdZeeeeeedd dedeje deje dejedejedejej&e e fdejej(ed eje defdZy)AsyncAlertsClientrc&t||_yr)rrrs rrzAsyncAlertsClient.__init__Ps/~Nrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawAlertsClient rr s rr!z#AsyncAlertsClient.with_raw_responseSr"rNr#r$r%r&r'r(cvK|jj|||||d{}|jS7w)a Find alerts Parameters ---------- page : typing.Optional[int] size : typing.Optional[int] sorting : typing.Optional[str] filters : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AlertPagePublic OK 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.alerts.find_alerts() asyncio.run(main()) r#Nr*r-s rr+zAsyncAlertsClient.find_alerts^sFN**66D'7Tc7  ~~ s $979r/r6r0r1r2r3r4r5c |K|jj||||||||d{} | jS7w)a Create alert Parameters ---------- webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import WebhookWrite import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.alerts.create_alert(webhook=WebhookWrite(url='url', ), ) asyncio.run(main()) r8Nr9r;s rr:zAsyncAlertsClient.create_alertsR`**77!+8   ~~  '<:<r<r=cpK|jj||d{}|jS7w)aR Delete multiple alerts by their IDs 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.alerts.delete_alert_batch(ids=['ids'], ) asyncio.run(main()) r?Nr@rBs rrAz$AsyncAlertsClient.delete_alert_batchs74**==#Wf=gg ~~h !646cpK|jj||d{}|jS7w)aG Get Alert by id Parameters ---------- id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AlertPublic Alert 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.alerts.get_alert_by_id(id='id', ) asyncio.run(main()) r<NrDrFs rrEz!AsyncAlertsClient.get_alert_by_ids62**::2:__ ~~`rirGc ~K|jj|||||||||  d{} | jS7w)a Update alert Parameters ---------- id_ : str webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- None Examples -------- from Opik import AsyncOpikApi from Opik import WebhookWrite import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.alerts.update_alert(id_='id', webhook=WebhookWrite(url='url', ), ) asyncio.run(main()) r8NrIrKs rrJzAsyncAlertsClient.update_alertsUf**77 !+8   ~~  s (=;=rLcpK|jj||d{}|jS7w)a Get webhook payload examples for all alert event types, optionally filtered by alert type Parameters ---------- alert_type : typing.Optional[GetWebhookExamplesRequestAlertType] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- WebhookExamples Webhook examples 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.alerts.get_webhook_examples() asyncio.run(main()) rLNrNrPs rrOz&AsyncAlertsClient.get_webhook_examples?s7<**??:gv?ww ~~xric |K|jj||||||||d{} | jS7w)a Test alert webhook Parameters ---------- webhook : WebhookWrite id : typing.Optional[str] name : typing.Optional[str] enabled : typing.Optional[bool] alert_type : typing.Optional[AlertWriteAlertType] metadata : typing.Optional[typing.Dict[str, str]] triggers : typing.Optional[typing.Sequence[AlertTriggerWrite]] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- WebhookTestResult Webhook test Examples -------- from Opik import AsyncOpikApi from Opik import WebhookWrite import asyncio client = AsyncOpikApi(api_key="YOUR_API_KEY", workspace_name="YOUR_WORKSPACE_NAME", ) async def main() -> None: await client.alerts.test_webhook(webhook=WebhookWrite(url='url', ), ) asyncio.run(main()) r8NrRr;s rrSzAsyncAlertsClient.test_webhook`sRb**77!+8   ~~  rg) rTrUrVrrrWrr!rXrYrZr[rrr+r\r r]r r^r_r r:rArrErJrr rOr rSr`rrrbrbOsO*<O #7  &*%)(,(,;?*ooc"*ooc" * % * % * 8* *`$(%))-;?;?HL;?:: OOC : ooc" : & :OO$78://&++c3h"78://&//2C"DE: 8: :z`dooc*=C__^=\ :dhQ_A`lwB$(%))-;?;?HL;?> > > OOC > ooc" >&>OO$78>//&++c3h"78>//&//2C"DE> 8> >FKO;? OO$FG 8   J$(%))-;?;?HL;?;; OOC ; ooc" ; & ;OO$78;//&++c3h"78;//&//2C"DE; 8; ;rrb)rXcore.client_wrapperrrcore.request_optionsrtypes.alert_page_publicrtypes.alert_publicrtypes.alert_trigger_writer types.alert_write_alert_typer types.webhook_examplesr types.webhook_test_resultr types.webhook_writer raw_clientrr-types.get_webhook_examples_request_alert_typercastAnyr\rrbr`rrr{s\G15,9>49.=]v{{6::s#wwt LLr