
    _jn                    &   S SK Jr  S SKJrJrJrJrJrJrJ	r	  S SK
Jr  S SKJr  S SKrSSKJrJrJrJrJrJrJrJr  SSKJrJrJrJrJr  SS	KJr  SS
K J!r!J"r"  SSK#J$r$J%r%J&r&J'r'  SSK(J)r)J*r*  SSK+J,r,J-r-J.r.J/r/J0r0J1r1  SSK2J3r3  SSK4J5r5  SSK6J7r7  SSK8J9r9  SSK:J;r;  SSK<J=r=  SSK>J?r?  SSK@JArA  SSKBJCrC  SSKDJErE  SSKFJGrG  / SQrH " S S\!5      rI " S S\"5      rJ " S S5      rK " S  S!5      rL " S" S#5      rM " S$ S%5      rN\IrO \JrP \KrQ \LrR \MrS \NrTg)&    )annotations)AnyDictListUnionIterableOptionalcast)chain)LiteralN   )BodyOmitQueryHeadersNoneTypeNotGivenomit	not_given)is_givenpath_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)StreamAsyncStream)findall_create_paramsfindall_enrich_paramsfindall_events_paramsfindall_extend_paramsfindall_ingest_paramsfindall_candidates_params)make_request_options)
FindAllRun)JsonSchemaParam)WebhookParam)FindAllSchema)McpServerParam)FindAllRunResult)ParallelBetaParam)MatchConditionParam)FindAllEventsResponse)FindAllCandidatesResponse)FindAllResourceAsyncFindAllResourceFindAllResourceWithRawResponse#AsyncFindAllResourceWithRawResponse$FindAllResourceWithStreamingResponse)AsyncFindAllResourceWithStreamingResponseFindallResourceAsyncFindallResourceFindallResourceWithRawResponse#AsyncFindallResourceWithRawResponse$FindallResourceWithStreamingResponse)AsyncFindallResourceWithStreamingResponsec            	         \ rS rSrSr\SS j5       r\SS j5       r\\\\SSS\	S.                           SS jjr
\SSS\	S.             SS	 jjr\SSS\	S.             SS
 jjr\SSS\	S.               SS jjr\\\SSS\	S.                   SS jjr\\\SSS\	S.                 SS jjr\SSS\	S.               SS jjr\SSS\	S.             SS jjr\SSS\	S.             S S jjr\SSS\	S.             S!S jjrSrg)"r5   :     
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
c                    [        U 5      $ z
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.

For more information, see https://www.github.com/parallel-web/parallel-sdk-python#accessing-raw-response-data-eg-headers
)r7   selfs    T/home/rurouni/.local/lib/python3.13/site-packages/parallel/resources/beta/findall.pywith_raw_response!FindAllResource.with_raw_response?   s     .d33    c                    [        U 5      $ z
An alternative to `.with_raw_response` that doesn't eagerly read the response body.

For more information, see https://www.github.com/parallel-web/parallel-sdk-python#with_streaming_response
)r9   rF   s    rH   with_streaming_response'FindAllResource.with_streaming_responseI   s     4D99rK   Nexclude_listmetadatawebhookbetasextra_headersextra_query
extra_bodytimeoutc               @   0 [        S[        U	5      (       a#  SR                  [        S U	 5       S/5      5      O[        05      EU
=(       d    0 En
SS0U
=(       d    0 En
U R                  S[        UUUUUUUUS.[        R                  5      [        XXS9[        S9$ )	u  
Starts a FindAll run.

This endpoint immediately returns a FindAll run object with status set to
'queued'. You can get the run result snapshot using the GET
/v1beta/findall/runs/{findall_id}/result endpoint. You can track the progress of
the run by:

- Polling the status using the GET /v1beta/findall/runs/{findall_id} endpoint,
- Subscribing to real-time updates via the
  /v1beta/findall/runs/{findall_id}/events endpoint,
- Or specifying a webhook with relevant event types during run creation to
  receive notifications.

Args:
  entity_type: Type of the entity for the FindAll run.

  generator: Generator for the FindAll run. One of base, core, pro, preview.

  match_conditions: List of match conditions for the FindAll run.

  match_limit: Maximum number of matches to find for this FindAll run. Must be between 5 and
      1000 (inclusive). May return fewer results.

  objective: Natural language objective of the FindAll run.

  exclude_list: List of entity names/IDs to exclude from results.

  metadata: Metadata for the FindAll run.

  webhook: Webhooks for Task Runs.

  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
parallel-beta,c              3  8   #    U  H  n[        U5      v   M     g 7fNstr.0es     rH   	<genexpr>)FindAllResource.create.<locals>.<genexpr>        4KUSVVU   findall-2025-09-15/v1beta/findall/runsentity_type	generatormatch_conditionsmatch_limit	objectiverQ   rR   rS   rU   rV   rW   rX   bodyoptionscast_to)r   r   joinr   r   _postr   r$   FindAllCreateParamsr*   r+   rG   rk   rl   rm   rn   ro   rQ   rR   rS   rT   rU   rV   rW   rX   s                 rH   createFindAllResource.createR   s    z	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXzz" #.!*(8#.!*$0 (&	 &99 )+Q[ %  
 	
rK   rT   rU   rV   rW   rX   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
W  
Retrieve a FindAll run.

Args:
  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
9Expected a non-empty value for `findall_id` but received r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   +FindAllResource.retrieve.<locals>.<genexpr>   rf   rg   rh   !/v1beta/findall/runs/{findall_id}
findall_idrp   rs   rt   

ValueErrorr   r   ru   r   r   _getr   r*   r+   rG   r   rT   rU   rV   rW   rX   s          rH   retrieveFindAllResource.retrieve   s    4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXyy=*U(+Q[   
 	
rK   c          
     ^   U(       d  [        SU< 35      eSS0U=(       d    0 En0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnUR                  SS05        U R                  [        SUS	9[        X4XVS
9[        S9$ )U  
Cancel a FindAll run.

Args:
  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   Accept*/*r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.cancel.<locals>.<genexpr>   rf   rg   rh   (/v1beta/findall/runs/{findall_id}/cancelr   rp   r   r   r   r   ru   r   r   updaterv   r   r*   r   r   s          rH   cancelFindAllResource.cancel   s    4 XYcXfghh!5B]-@bB	
# &)XXe4KU4KNbMc.d%e"	
 "	
 	o/CDEzzDQ[\(+Q[   
 	
rK   rn   rU   rV   rW   rX   c                   SS0U=(       d    0 EnU R                  S[        UUUS.[        R                  5      [	        XEXgS9[
        S9$ )  
Return ranked entity candidates matching a natural language objective.

This endpoint performs a best-effort search optimised for low latency. For
comprehensive match evaluation and enrichment, use the
[FindAll API](https://docs.parallel.ai/findall-api/findall-quickstart).

Args:
  entity_type: Type of entity to search for.

  objective: Natural language description of target entities.

  match_limit: Maximum number of candidates to return. Must be between 5 and 1000 (inclusive).
      May return fewer results. Defaults to 100.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r[   rh   /v1beta/findall/candidatesrk   ro   rn   rp   rq   )rv   r   r)   FindAllCandidatesParamsr*   r4   rG   rk   ro   rn   rU   rV   rW   rX   s           rH   
candidatesFindAllResource.candidates  sj    H )*>X=CVTVXzz( #.!*#.
 *AA )+Q[ .  
 	
rK   mcp_servers	processorrT   rU   rV   rW   rX   c               r   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUS.[        R                  5      [        XgXS	9[        S
9$ )  
Add an enrichment to a FindAll run.

Args:
  output_schema: JSON schema for the enrichment output schema for the FindAll run.

  mcp_servers: List of MCP servers to use for the task.

  processor: Processor to use for the task.

  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.enrich.<locals>.<genexpr>k  rf   rg   rh   (/v1beta/findall/runs/{findall_id}/enrichr   output_schemar   r   rp   rq   )r   r   r   ru   r   r   rv   r   r   r%   FindAllEnrichParamsr*   r.   
rG   r   r   r   r   rT   rU   rV   rW   rX   s
             rH   enrichFindAllResource.enrichC  s    F XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXzzDQ[\ %2#.!*
 &99 )+Q[ "  
 	
rK   last_event_idapi_timeoutrT   rU   rV   rW   rX   c                  U(       d  [        SU< 35      eSS0U=(       d    0 En0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS	9[        UUUU[        UUS
.[        R                  5      S9[        [        [        5      S[        [           S9$ )\  
Stream events from a FindAll run.

Args: request: The Shapi request findall_id: The FindAll run ID last_event_id:
Optional event ID to resume from. timeout: Optional timeout in seconds. If None,
keep connection alive as long as the run is going. If set, stop after specified
duration.

Args:
  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   r   text/event-streamr[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.events.<locals>.<genexpr>  rf   rg   rh   (/v1beta/findall/runs/{findall_id}/eventsr   r   r   rU   rV   rW   rX   queryTrs   rt   stream
stream_cls)r   r   r   ru   r   r   r   r   r*   r   r&   FindAllEventsParamsr
   r   r3   r"   	rG   r   r   r   rT   rU   rV   rW   rX   s	            rH   eventsFindAllResource.events  s   B XYcXfghh!#6P=;NBP	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXyyDQ[\(+'%%)6'2 *== 3434#  
 	
rK   c               n   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        SU0[        R                  5      [        XEXgS	9[        S
9$ )c  
Extend a FindAll run by adding additional matches to the current match limit.

Args:
  additional_match_limit: Additional number of matches to find for this FindAll run. This value will be
      added to the current match limit to determine the new total match limit. Must be
      greater than 0.

  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.extend.<locals>.<genexpr>  rf   rg   rh   (/v1beta/findall/runs/{findall_id}/extendr   additional_match_limitrp   rq   )r   r   r   ru   r   r   rv   r   r   r'   FindAllExtendParamsr*   r.   rG   r   r   rT   rU   rV   rW   rX   s           rH   extendFindAllResource.extend  s    > XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXzzDQ[\ )+ABDYDmDm )+Q[ "  	
 		
rK   c               2   0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        SU0[        R                  5      [        X4XVS9[        S9$ )	  
Transforms a natural language search objective into a structured FindAll spec.

Note: Access to this endpoint requires the parallel-beta header.

The generated specification serves as a suggested starting point and can be
further customized by the user.

Args:
  objective: Natural language objective to create a FindAll run spec.

  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.ingest.<locals>.<genexpr>!  rf   rg   rh   /v1beta/findall/ingestro   rp   rq   )r   r   ru   r   r   rv   r   r(   FindAllIngestParamsr*   r.   rG   ro   rT   rU   rV   rW   rX   s          rH   ingestFindAllResource.ingest  s    B	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXzz$ +y!9;P;d;de(+Q[ "  
 	
rK   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
{  
Retrieve the FindAll run result at the time of the request.

Args:
  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.result.<locals>.<genexpr>Q  rf   rg   rh   (/v1beta/findall/runs/{findall_id}/resultr   rp   r   
r   r   r   ru   r   r   r   r   r*   r0   r   s          rH   resultFindAllResource.result2  s    4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXyyDQ[\(+Q[ %  
 	
rK   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
V  
Get FindAll Run Schema

Args:
  betas: Optional header to specify the beta version(s) to enable.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   )FindAllResource.schema.<locals>.<genexpr>  rf   rg   rh   (/v1beta/findall/runs/{findall_id}/schemar   rp   r   
r   r   r   ru   r   r   r   r   r*   r.   r   s          rH   schemaFindAllResource.schemaa  s    4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXyyDQ[\(+Q[ "  
 	
rK    )returnr7   )r   r9   rk   r`   rl   z)Literal['base', 'core', 'pro', 'preview']rm   zIterable[MatchConditionParam]rn   intro   r`   rQ   z<Optional[Iterable[findall_create_params.ExcludeList]] | OmitrR   z3Optional[Dict[str, Union[str, float, bool]]] | OmitrS   zOptional[WebhookParam] | OmitrT   List[ParallelBetaParam] | OmitrU   Headers | NonerV   Query | NonerW   Body | NonerX   'float | httpx.Timeout | None | NotGivenr   r+   r   r`   rT   r   rU   r   rV   r   rW   r   rX   r   r   r+   r   r`   rT   r   rU   r   rV   r   rW   r   rX   r   r   Nonerk   zLiteral['company', 'people']ro   r`   rn   z
int | OmitrU   r   rV   r   rW   r   rX   r   r   r4   r   r`   r   r,   r   z)Optional[Iterable[McpServerParam]] | Omitr   z
str | OmitrT   r   rU   r   rV   r   rW   r   rX   r   r   r.   )r   r`   r   Optional[str] | Omitr   Optional[float] | OmitrT   r   rU   r   rV   r   rW   r   rX   r   r   zStream[FindAllEventsResponse]r   r`   r   r   rT   r   rU   r   rV   r   rW   r   rX   r   r   r.   ro   r`   rT   r   rU   r   rV   r   rW   r   rX   r   r   r.   r   r`   rT   r   rU   r   rV   r   rW   r   rX   r   r   r0   r   r`   rT   r   rU   r   rV   r   rW   r   rX   r   r   r.   __name__
__module____qualname____firstlineno____doc__r   rI   rN   r   r   ry   r   r   r   r   r   r   r   r   r   __static_attributes__r   rK   rH   r5   r5   :   s    4 4 : :  VZHL1504 )-$("&;D#[
 [
 =	[

 8[
 [
 [
 S[
 F[
 /[
 .[
 &[
 "[
   ![
" 9#[
$ 
%[
B 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
f 15 )-$("&;D.
.
 .	.
 &.
 ".
  .
 9.
 
.
j #' )-$("&;D3
 23
 	3

  3
 &3
 "3
  3
 93
 
#3
t BF $04 )-$("&;D>
>
 '	>

 ?>
 >
 .>
 &>
 ">
  >
 9>
 
>
H /3.204 )-$("&;DA
A
 ,	A

 ,A
 .A
 &A
 "A
  A
 9A
 
'A
P 15 )-$("&;D5
5
 !$	5

 .5
 &5
 "5
  5
 95
 
5
v 15 )-$("&;D3
 3
 .	3
 &3
 "3
  3
 93
 
3
r 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
f 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
 -
rK   r5   c            	         \ rS rSrSr\SS j5       r\SS j5       r\\\\SSS\	S.                           SS jjr
\SSS\	S.             SS	 jjr\SSS\	S.             SS
 jjr\SSS\	S.               SS jjr\\\SSS\	S.                   SS jjr\\\SSS\	S.                 SS jjr\SSS\	S.               SS jjr\SSS\	S.             SS jjr\SSS\	S.             S S jjr\SSS\	S.             S!S jjrSrg)"r6   i  rC   c                    [        U 5      $ rE   )r8   rF   s    rH   rI   &AsyncFindAllResource.with_raw_response  s     3488rK   c                    [        U 5      $ rM   )r:   rF   s    rH   rN   ,AsyncFindAllResource.with_streaming_response  s     9>>rK   NrP   c               p  #    0 [        S[        U	5      (       a#  SR                  [        S U	 5       S/5      5      O[        05      EU
=(       d    0 En
SS0U
=(       d    0 En
U R                  S[        UUUUUUUUS.[        R                  5      I Sh  vN [        XXS9[        S	9I Sh  vN $  N N7f)
rZ   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.create.<locals>.<genexpr>  rf   rg   rh   ri   rj   Nrp   rq   )r   r   ru   r   r   rv   r   r$   rw   r*   r+   rx   s                 rH   ry   AsyncFindAllResource.create  s     z	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXZZ",#.!*(8#.!*$0 (&	 &99  )+Q[ %   
 
 	

s$   BB6B2
B6-B4.B64B6r{   c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r}   r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   0AsyncFindAllResource.retrieve.<locals>.<genexpr>%  rf   rg   rh   r   r   rp   r   Nr   r   s          rH   r   AsyncFindAllResource.retrieve  s     4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXYY=*U(+Q[   
 
 	
 
   BB(!B&"B(c          
     z  #    U(       d  [        SU< 35      eSS0U=(       d    0 En0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnUR                  SS05        U R                  [        SUS	9[        X4XVS
9[        S9I Sh  vN $  N7f)r   r~   r   r   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.cancel.<locals>.<genexpr>U  rf   rg   rh   r   r   rp   r   Nr   r   s          rH   r   AsyncFindAllResource.cancel5  s     4 XYcXfghh!5B]-@bB	
# &)XXe4KU4KNbMc.d%e"	
 "	
 	o/CDEZZDQ[\(+Q[    
 
 	
 
s   B2B;4B95B;r   c                  #    SS0U=(       d    0 EnU R                  S[        UUUS.[        R                  5      I Sh  vN [	        XEXgS9[
        S9I Sh  vN $  N N7f)r   r[   rh   r   r   Nrp   rq   )rv   r   r)   r   r*   r4   r   s           rH   r   AsyncFindAllResource.candidatese  s     H )*>X=CVTVXZZ(,#.!*#.
 *AA  )+Q[ .   
 
 	

s"   =A A
 A AA A r   c                 #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUS.[        R                  5      I S	h  vN [        XgXS
9[        S9I S	h  vN $  N N7f)r   r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.enrich.<locals>.<genexpr>  rf   rg   rh   r   r   r   Nrp   rq   )r   r   r   ru   r   r   rv   r   r   r%   r   r*   r.   r   s
             rH   r   AsyncFindAllResource.enrich  s     F XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXZZDQ[\,%2#.!*
 &99  )+Q[ "   
 
 	

s$   B,C.C
/CCCCr   c                 #    U(       d  [        SU< 35      eSS0U=(       d    0 En0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS	9[        UUUU[        UUS
.[        R                  5      I Sh  vN S9[        [        [        5      S[        [           S9I Sh  vN $  N0 N7f)r   r~   r   r   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.events.<locals>.<genexpr>  rf   rg   rh   r   r   r   Nr   Tr   )r   r   r   ru   r   r   r   r   r*   r   r&   r   r
   r   r3   r#   r   s	            rH   r   AsyncFindAllResource.events  s$    B XYcXfghh!#6P=;NBP	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXYYDQ[\(+'%1)6'2 *==  34"#89#  
 
 	

s$   CC:C6+C:1C82C:8C:c                 #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        SU0[        R                  5      I S	h  vN [        XEXgS
9[        S9I S	h  vN $  N N7f)r   r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.extend.<locals>.<genexpr>A  rf   rg   rh   r   r   r   Nrp   rq   )r   r   r   ru   r   r   rv   r   r   r'   r   r*   r.   r   s           rH   r   AsyncFindAllResource.extend  s     > XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXZZDQ[\,)+ABDYDmDm  )+Q[ "   	
 	
 		
	
s$   B*C,C	
-CCCCc               b  #    0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        SU0[        R                  5      I Sh  vN [        X4XVS9[        S	9I Sh  vN $  N N7f)
r   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.ingest.<locals>.<genexpr>x  rf   rg   rh   r   ro   Nrp   rq   )r   r   ru   r   r   rv   r   r(   r   r*   r.   r   s          rH   r   AsyncFindAllResource.ingestT  s     B	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXZZ$,k9-EG\GpGpqq(+Q[ "   
 
 	
q
s$   BB/B+
B/&B-'B/-B/c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r   r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.result.<locals>.<genexpr>  rf   rg   rh   r   r   rp   r   Nr   r   s          rH   r   AsyncFindAllResource.result  s     4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXYYDQ[\(+Q[ %  
 
 	
 
r  c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r   r~   r[   r\   c              3  8   #    U  H  n[        U5      v   M     g 7fr^   r_   ra   s     rH   rd   .AsyncFindAllResource.schema.<locals>.<genexpr>  rf   rg   rh   r   r   rp   r   Nr   r   s          rH   r   AsyncFindAllResource.schema  s     4 XYcXfghh	
# &)XXe4KU4KNbMc.d%e"	
 "	
 )*>X=CVTVXYYDQ[\(+Q[ "  
 
 	
 
r  r   )r   r8   )r   r:   r   r   r   r   r   )r   r`   r   r   r   r   rT   r   rU   r   rV   r   rW   r   rX   r   r   z"AsyncStream[FindAllEventsResponse]r   r   r   r   r   r   rK   rH   r6   r6     s    9 9 ? ?  VZHL1504 )-$("&;D#[
 [
 =	[

 8[
 [
 [
 S[
 F[
 /[
 .[
 &[
 "[
   ![
" 9#[
$ 
%[
B 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
f 15 )-$("&;D.
.
 .	.
 &.
 ".
  .
 9.
 
.
j #' )-$("&;D3
 23
 	3

  3
 &3
 "3
  3
 93
 
#3
t BF $04 )-$("&;D>
>
 '	>

 ?>
 >
 .>
 &>
 ">
  >
 9>
 
>
H /3.204 )-$("&;DA
A
 ,	A

 ,A
 .A
 &A
 "A
  A
 9A
 
,A
P 15 )-$("&;D5
5
 !$	5

 .5
 &5
 "5
  5
 95
 
5
v 15 )-$("&;D3
 3
 .	3
 &3
 "3
  3
 93
 
3
r 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
f 15 )-$("&;D-
-
 .	-
 &-
 "-
  -
 9-
 
-
 -
rK   r6   c                      \ rS rSrSS jrSrg)r7   i  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l	        [        UR                  5      U l
        [        UR                  5      U l        g r^   )_findallr   ry   r   r   r   r   r   r   r   r   r   rG   findalls     rH   __init__'FindAllResourceWithRawResponse.__init__  s    -NN
 0
 .NN
 2
 .NN
 .NN
 .NN
 .NN
 .NN
 .NN
rK   r,  r   r   ry   r   r   r   r   r   r   r   Nr.  r5   r   r   r   r   r   r   r/  r   r   rK   rH   r7   r7          
rK   r7   c                      \ rS rSrSS jrSrg)r8   i  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l	        [        UR                  5      U l
        [        UR                  5      U l        g r^   )r,  r    ry   r   r   r   r   r   r   r   r   r   r-  s     rH   r/  ,AsyncFindAllResourceWithRawResponse.__init__  s    3NN
 6
 4NN
 8
 4NN
 4NN
 4NN
 4NN
 4NN
 4NN
rK   r1  Nr.  r6   r   r   r3  r   rK   rH   r8   r8     r4  rK   r8   c                      \ rS rSrSS jrSrg)r9   i0  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l	        [        UR                  5      U l
        [        UR                  5      U l        g r^   )r,  r   ry   r   r   r   r   r   r   r   r   r   r-  s     rH   r/  -FindAllResourceWithStreamingResponse.__init__1  s    2NN
 5
 3NN
 7
 3NN
 3NN
 3NN
 3NN
 3NN
 3NN
rK   r1  Nr2  r3  r   rK   rH   r9   r9   0  r4  rK   r9   c                      \ rS rSrSS jrSrg)r:   iT  c                   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l	        [        UR                  5      U l
        [        UR                  5      U l        g r^   )r,  r!   ry   r   r   r   r   r   r   r   r   r   r-  s     rH   r/  2AsyncFindAllResourceWithStreamingResponse.__init__U  s    8NN
 ;
 9NN
 =
 9NN
 9NN
 9NN
 9NN
 9NN
 9NN
rK   r1  Nr8  r3  r   rK   rH   r:   r:   T  r4  rK   r:   )U
__future__r   typingr   r   r   r   r   r	   r
   	itertoolsr   typing_extensionsr   httpx_typesr   r   r   r   r   r   r   r   _utilsr   r   r   r   r   _compatr   	_resourcer   r   	_responser   r   r    r!   
_streamingr"   r#   
types.betar$   r%   r&   r'   r(   r)   _base_clientr*   types.beta.findall_runr+   types.json_schema_paramr,   types.beta.webhook_paramr-   types.beta.findall_schemar.   types.beta.mcp_server_paramr/   types.beta.findall_run_resultr0   types.beta.parallel_beta_paramr1    types.beta.match_condition_paramr2   "types.beta.findall_events_responser3   &types.beta.findall_candidates_responser4   __all__r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   r@   r   rK   rH   <module>rW     s    # C C C  %  U U U f f & :  .  1 0 6 4 6 9 = ? C G O T	
o T	
nT	
+ T	
n!
 !
H!
 !
H!
 !
H!
 !
H " B+  G!?  Q&I # V'K $ W . * ]rK   