+
    Wi8                    .   ^ RI Ht ^ RIt^ RIt^ RIHtHtHtHtH	t	H
t
HtHtHt ^RIHtHtHtHtHtHtHtHtHt ^RIHt ^RIHt ^RIHtHt ^RIH t H!t! ^R	I"H#t#H$t$ ^R
I%H&t&H't' ^RI(H)t)H*t* ^RI+H,t,H-t- ^RI.H/t/H0t0  ! R R]4      t1 ! R R]4      t2R# )    )annotationsN)	ListOptionalLiteralDictAnyUnionIteratorAsyncIteratorCallable)	WebsetListWebsetsResponseGetWebsetResponseUpdateWebsetRequestWebsetStatusCreateWebsetParametersPreviewWebsetParametersPreviewWebsetResponseRequestOptions)WebsetsBaseClient)WebsetsAsyncBaseClient)WebsetItemsClientAsyncWebsetItemsClient)WebsetSearchesClientAsyncWebsetSearchesClient)WebsetEnrichmentsClientAsyncWebsetEnrichmentsClient)WebsetWebhooksClientAsyncWebsetWebhooksClient)MonitorsClientAsyncMonitorsClient)ImportsClientAsyncImportsClient)EventsClientAsyncEventsClientc                     a  ] tR t^tRtV 3R ltR R R lltR R ltRR/R	 R
 lltRRRR/R R llt	R R lt
R R ltR R ltRR/R R lltRR/R R lltRRR^RR/R R lltRtV ;t# )!WebsetsClientzClient for managing Websets.c                	  < \         SV `  V4       \        V4      V n        \	        V4      V n        \        V4      V n        \        V4      V n	        \        V4      V n        \        V4      V n        \        V4      V n        R # N)super__init__r   itemsr   searchesr   enrichmentsr   webhooksr    monitorsr"   importsr$   eventsselfclient	__class__s   &&T/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/exa_py/websets/client.pyr+   WebsetsClient.__init__   se     &v.
,V426:,V4&v.$V,"6*    Nc               $    V ^8  d   QhRRRRRR/#    paramsz-Union[Dict[str, Any], CreateWebsetParameters]optionsz/Optional[Union[Dict[str, Any], RequestOptions]]returnr    )formats   "r7   __annotate__WebsetsClient.__annotate__)   s$     / /J /G/SY/r9   c                T    V P                  RWR7      p\        P                  ! V4      # )/  Create a new Webset.

Args:
    params (CreateWebsetParameters): The parameters for creating a webset.
    options (RequestOptions, optional): Request options including priority and/or custom headers.
        Can specify priority as 'low', 'medium', or 'high'.

Returns:
    Webset: The created webset.
/v0/websetsdatar>   requestr   model_validater4   r=   r>   responses   &&& r7   createWebsetsClient.create)   s'     <<F<L$$X..r9   c                    V ^8  d   QhRRRR/# r<   r=   z.Union[Dict[str, Any], PreviewWebsetParameters]r?   r   r@   )rA   s   "r7   rB   rC   8   s     > >L >Qf >r9   c                T    V P                  RVR7      p\        P                  ! V4      # )a  Preview a webset query.

Preview how a search query will be decomposed before creating a webset. 
This endpoint performs the same query analysis that happens during webset creation, 
allowing you to see the detected entity type, generated search criteria, and 
available enrichment columns in advance.

Args:
    params (PreviewWebsetParameters): The parameters for previewing a webset.

Returns:
    PreviewWebsetResponse: The preview response showing how the query will be decomposed.
/v0/websets/previewrH   rJ   r   rK   r4   r=   rM   s   && r7   previewWebsetsClient.preview8   s(     << 5F<C$33H==r9   expandc               $    V ^8  d   QhRRRRRR/# r<   idstrrY   z Optional[List[Literal['items']]]r?   r   r@   )rA   s   "r7   rB   rC   I   s#     : :c :&F :Rc :r9   c               x    V'       d   RV/M/ pV P                  RV 2VRR7      p\        P                  ! V4      # )a  Get a Webset by ID.

Args:
    id (str): The id or externalId of the Webset.
    expand (List[Literal["items"]], optional): Expand the response with specified resources.
        Allowed values: ["items"]

Returns:
    GetWebsetResponse: The retrieved webset.
rY   /v0/websets/GETr=   methodrJ   r   rK   r4   r\   rY   r=   rM   s   &&$  r7   getWebsetsClient.getI   s>     (.(F#2<<,rd 3F5<Q //99r9   cursorlimitc               $    V ^8  d   QhRRRRRR/# r<   rg   zOptional[str]rh   Optional[int]r?   r   r@   )rA   s   "r7   rB   rC   X   s"     < <m <= <Tg <r9   c                   RVRV/P                  4        UUu/ uF  w  r4Vf   K  W4bK  	  pppV P                  RVRR7      p\        P                  ! V4      # u uppi )List all Websets.

Args:
    cursor (str, optional): The cursor to paginate through the results.
    limit (int, optional): The number of results to return (max 200).

Returns:
    ListWebsetsResponse: List of websets.
rg   rh   rF   r`   ra   r,   rJ   r   rK   r4   rg   rh   kvr=   rM   s   &$$    r7   listWebsetsClient.listX   s`     %-fgu#E#K#K#M_#M41QR$!$#M_<<fU<K"11(;; `s
   AAc               $    V ^8  d   QhRRRRRR/# r<   r\   r]   r=   z*Union[Dict[str, Any], UpdateWebsetRequest]r?   r   r@   )rA   s   "r7   rB   rC   f   s#     / / /&P /U[ /r9   c                \    V P                  RV 2VRR7      p\        P                  ! V4      # )Update a Webset.

Args:
    id (str): The id or externalId of the Webset.
    params (UpdateWebsetRequest): The parameters for updating a webset.

Returns:
    Webset: The updated webset.
r_   POSTrH   rb   rI   r4   r\   r=   rM   s   &&& r7   updateWebsetsClient.updatef   s0     <<,rd 3&<P$$X..r9   c                    V ^8  d   QhRRRR/# r<   r\   r]   r?   r   r@   )rA   s   "r7   rB   rC   s        
/ 
/ 
/ 
/r9   c                Z    V P                  RV 2RR7      p\        P                  ! V4      # )tDelete a Webset.

Args:
    id (str): The id or externalId of the Webset.

Returns:
    Webset: The deleted webset.
r_   DELETErb   rI   r4   r\   rM   s   && r7   deleteWebsetsClient.deletes   s.     <<,rd 3H<E$$X..r9   c                    V ^8  d   QhRRRR/# r~   r@   )rA   s   "r7   rB   rC      r   r9   c                \    V P                  RV R2RR7      p\        P                  ! V4      # )}Cancel a running Webset.

Args:
    id (str): The id or externalId of the Webset.

Returns:
    Webset: The canceled webset.
r_   /cancelrx   r   rI   r   s   && r7   cancelWebsetsClient.cancel   s0     <<,rd' :6<J$$X..r9   c                    V ^8  d   QhRRRR/# )r<   rh   rk   r?   zIterator[Webset]r@   )rA   s   "r7   rB   rC      s     * * *:J *r9   c             #     "   Rp V P                  W!R7      pVP                   F  pVx  K	  	  VP                  '       d   VP                  '       g   R# VP                  pK^  5izIterate through all Websets, handling pagination automatically.

Args:
    limit (int, optional): The number of results to return per page (max 200).
    
Yields:
    Webset: Each webset.
N)rg   rh   rr   rH   has_morenext_cursorr4   rh   rg   rM   websets   &$   r7   list_allWebsetsClient.list_all   sY      yyy<H"-- ( $$$H,@,@,@))Fs   >A#A#A#c                    V ^8  d   QhRRRR/# r<   rh   rk   r?   zList[Webset]r@   )rA   s   "r7   rB   rC      s     	0 	0 	0 	0r9   c               8    \        V P                  VR7      4      # )Collect all Websets into a list.

Args:
    limit (int, optional): The number of results to return per page (max 200).
    
Returns:
    List[Webset]: All websets.
rh   )rr   r   )r4   rh   s   &$r7   get_allWebsetsClient.get_all   s     DMMM.//r9   timeout  poll_intervalon_pollc          
     ,    V ^8  d   QhRRRRRRRRRR	/# 
r<   r\   r]   r   intr   r   z"Optional[Callable[[Webset], None]]r?   r   r@   )rA   s   "r7   rB   rC      s<     #& #&#& 	#&
 #& 4#& 
#&r9   c               \   \         P                   ! 4       p V P                  V4      pV'       d	   V! V4       VP                  \        P                  P
                  8X  d   V# \         P                   ! 4       V,
          V8  d   \        RV RV R24      h\         P                  ! V4       K  )  Wait until a Webset is idle.

Args:
    id (str): The id or externalId of the Webset.
    timeout (int, optional): Maximum time to wait in seconds. Defaults to 3600.
    poll_interval (int, optional): Time to wait between polls in seconds. Defaults to 5.
    on_poll (Callable[[Webset], None], optional): Callback function called on each poll with the current webset.
    
Returns:
    Webset: The webset once it's idle.
    
Raises:
    TimeoutError: If the webset does not become idle within the timeout period.
Webset  did not become idle within  seconds)timere   statusr   idlevalueTimeoutErrorsleepr4   r\   r   r   r   
start_timer   s   &&$$$  r7   wait_until_idleWebsetsClient.wait_until_idle   s    , YY[
XXb\F}} 1 1 7 77yy{Z''1"WRD0LWIU]#^__JJ}%r9   r.   r2   r1   r,   r0   r-   r/   r)   __name__
__module____qualname____firstlineno____doc__r+   rN   rW   re   rr   r{   r   r   r   r   r   __static_attributes____classcell__r6   s   @r7   r'   r'      s    &+/>": :<d <4 </
/
/* *(	0 	0#& 	#&
 #& 7;#& #&r9   r'   c                     a  ] tR t^tRtV 3R ltR R R lltR R ltRR/R	 R
 lltRRRR/R R llt	R R lt
R R ltR R ltRR/R R lltRR/R R lltRRR^RR/R R lltRtV ;t# )!AsyncWebsetsClientz"Async client for managing Websets.c                	  < \         SV `  V4       \        V4      V n        \	        V4      V n        \        V4      V n        \        V4      V n	        \        V4      V n        \        V4      V n        \        V4      V n        R # r)   )r*   r+   r   r,   r   r-   r   r.   r   r/   r!   r0   r#   r1   r%   r2   r3   s   &&r7   r+   AsyncWebsetsClient.__init__   se     +F3
1&97?1&9+F3)&1'/r9   Nc               $    V ^8  d   QhRRRRRR/# r;   r@   )rA   s   "r7   rB   AsyncWebsetsClient.__annotate__   s$     / /#P /M/Y_/r9   c                p   "   V P                  RWR7      G Rj  xL
 p\        P                  ! V4      #  L5i)rE   rF   rG   NrI   rL   s   &&& r7   rN   AsyncWebsetsClient.create   s3      m&RR$$X.. S   646c                    V ^8  d   QhRRRR/# rQ   r@   )rA   s   "r7   rB   r      s     
> 
>$R 
>Wl 
>r9   c                p   "   V P                  RVR7      G Rj  xL
 p\        P                  ! V4      #  L5i)zPreview a Webset before creating it.

Args:
    params (PreviewWebsetParameters): The parameters for previewing a webset.

Returns:
    PreviewWebsetResponse: The preview results.
rS   rT   NrU   rV   s   && r7   rW   AsyncWebsetsClient.preview   s4      &;&II$33H== Jr   rY   c               $    V ^8  d   QhRRRRRR/# r[   r@   )rA   s   "r7   rB   r      s#     : :C :,L :Xi :r9   c                  "   / pVe   W#R&   V P                  RV 2VRR7      G Rj  xL
 p\        P                  ! V4      #  L5i)zGet a Webset by ID.

Args:
    id (str): The id or externalId of the Webset.
    expand (List[Literal["items"]], optional): Expand items in the response.

Returns:
    GetWebsetResponse: The retrieved webset.
NrY   r_   r`   ra   rc   rd   s   &&$  r7   re   AsyncWebsetsClient.get   sP      %8RD&9&QVWW //99 Xs   %AAArg   rh   c               $    V ^8  d   QhRRRRRR/# rj   r@   )rA   s   "r7   rB   r   	  s"     < <M < <Zm <r9   c                  "   RVRV/P                  4        UUu/ uF  w  r4Vf   K  W4bK  	  pppV P                  RVRR7      G Rj  xL
 p\        P                  ! V4      # u uppi  L 5i)rm   rg   rh   NrF   r`   ra   rn   ro   s   &$$    r7   rr   AsyncWebsetsClient.list	  si      %-fgu#E#K#K#M_#M41QR$!$#M_mF5QQ"11(;; `Qs    A*A"A"A*A(!A*c               $    V ^8  d   QhRRRRRR/# ru   r@   )rA   s   "r7   rB   r     s#     / /s /,V /[a /r9   c                x   "   V P                  RV 2VRR7      G Rj  xL
 p\        P                  ! V4      #  L5i)rw   r_   rx   ry   NrI   rz   s   &&& r7   r{   AsyncWebsetsClient.update  s<      RD&9vVV$$X.. W   :8:c                    V ^8  d   QhRRRR/# r~   r@   )rA   s   "r7   rB   r   $       
/ 
/s 
/v 
/r9   c                v   "   V P                  RV 2RR7      G Rj  xL
 p\        P                  ! V4      #  L5i)r   r_   r   r   NrI   r   s   && r7   r   AsyncWebsetsClient.delete$  s:      RD&9(KK$$X.. Ls   979c                    V ^8  d   QhRRRR/# r~   r@   )rA   s   "r7   rB   r   0  r   r9   c                x   "   V P                  RV R2RR7      G Rj  xL
 p\        P                  ! V4      #  L5i)r   r_   r   rx   r   NrI   r   s   && r7   r   AsyncWebsetsClient.cancel0  s<      RD&@PP$$X.. Qr   c                    V ^8  d   QhRRRR/# )r<   rh   rk   r?   zAsyncIterator[Webset]r@   )rA   s   "r7   rB   r   <  s     * *} *@U *r9   c                 "   Rp V P                  W!R7      G Rj  xL
 pVP                   F  pV5x  K
  	  VP                  '       d   VP                  '       g   R# VP                  pKg   LP5ir   r   r   s   &$   r7   r   AsyncWebsetsClient.list_all<  sb      !YYfYBBH"-- ( $$$H,@,@,@))F Cs   A.A,-A.
A.A.c                    V ^8  d   QhRRRR/# r   r@   )rA   s   "r7   rB   r   P  s      m | r9   c               v   "   . pV P                  VR7        Rj  xL
  pVP                  V4       K   LDT# 5i)r   r   N)r   append)r4   rh   websetsr   s   &$  r7   r   AsyncWebsetsClient.get_allP  s?       MMM6 	# 	#&NN6"	#6s   9646969r   r   r   r   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# r   r@   )rA   s   "r7   rB   r   ^  s<     #/ #/#/ 	#/
 #/ 4#/ 
#/r9   c                 "   \         P                  ! 4       P                  4       p V P                  V4      G Rj  xL
 pV'       d	   V! V4       VP                  \
        P                  P                  8X  d   V# \         P                  ! 4       P                  4       V,
          V8  d   \        RV RV R24      h\         P                  ! V4      G Rj  xL
  K   L L5i)r   Nr   r   r   )
asyncioget_event_loopr   re   r   r   r   r   r   r   r   s   &&$$$  r7   r   "AsyncWebsetsClient.wait_until_idle^  s     , ++-224
88B<'F}} 1 1 7 77%%',,.;gE"WRD0LWIU]#^__--... ( /s(   9C CC BC CC C r   r)   r   r   s   @r7   r   r      s    ,0/
>:t :"<D <QU </
/
/*t *(d #/ 	#/
 #/ 7;#/ #/r9   r   )3
__future__r   r   r   typingr   r   r   r   r   r	   r
   r   r   typesr   r   r   r   r   r   r   r   r   	core.baser   core.async_baser   r,   r   r   r-   r   r   r.   r   r   r/   r   r   r0   r    r!   r1   r"   r#   r2   r$   r%   r'   r   r@   r9   r7   <module>r      sb    "   _ _ _
 
 
 ) 3 < E N E 9 6 3q&% q&hq// q/r9   