+
    UiUQ                       ^ RI Ht ^ RIt^ RIHtHtHt ^ RIHtH	t	 ^ RI
t
^RIHt ^RIHt ^RIHtHtHtHtHtHtHt ^RI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%H&t& ]'       d   ^RI'H(t(H)t) ^RI*H+t+H,t, ^RI-H.t.H/t/ . ROt0 ! R R]%4      t1 ! R R]&4      t2 ! R R4      t3 ! R R4      t4 ! R R4      t5 ! R R4      t6]1t7]2t8R# )    )annotationsN)TYPE_CHECKINGAnyMapping)Selfoverride)_exceptionsQuerystring)OmitTimeoutNotGiven	TransportProxiesTypesRequestOptions	not_given)is_givenget_async_library)cached_property)__version__)StreamAsyncStream)ParallelErrorAPIStatusError)DEFAULT_MAX_RETRIESSyncAPIClientAsyncAPIClient)betatask_run)TaskRunResourceAsyncTaskRunResource)BetaResourceAsyncBetaResourceParallelAsyncParallelc                  n  a  ] tR t^2t$ R]R&   RRRRR]R]RRRRR	RR
R/R V 3R lllt]R R l4       t	]R R l4       t
]R R l4       t]R R l4       t]]R R l4       4       t]]R R l4       4       t]]R V 3R ll4       4       tRRRRR]R	RR]RRRRRRRRR/ /
R R  llt]t]R! R" l4       tR#tV ;t# )$r$   strapi_keyNbase_urltimeoutmax_retriesdefault_headersdefault_queryhttp_client_strict_response_validationFc               <    V ^8  d   QhRRRRRRRRR	R
RRRRRRRR/	# )   r(   
str | Noner)   str | httpx.URL | Noner*   !float | Timeout | None | NotGivenr+   intr,   Mapping[str, str] | Noner-   Mapping[str, object] | Noner.   httpx.Client | Noner/   boolreturnNone )formats   "O/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/parallel/_client.py__annotate__Parallel.__annotate__6   sf     1
 1
 1
 )	1

 31
 1
 21
 31
 )1
* &*+1
, 
-1
    c                  < Vf    \         P                  P                  R4      pVf   \        R4      hWn        Vf    \         P                  P                  R4      pVf   Rp\
        S	V `  \        VVVVVVVR7       R# )zConstruct a new synchronous Parallel client instance.

This automatically infers the `api_key` argument from the `PARALLEL_API_KEY` environment variable if it is not provided.
NPARALLEL_API_KEYThe api_key client option must be set either by passing api_key to the client or by setting the PARALLEL_API_KEY environment variablePARALLEL_BASE_URLhttps://api.parallel.aiversionr)   r+   r*   r.   custom_headerscustom_queryr/   osenvirongetr   r(   super__init__r   
selfr(   r)   r*   r+   r,   r-   r.   r/   	__class__s
   &$$$$$$$$r>   rP   Parallel.__init__6       6 ?jjnn%78G? X  zz~~&9:H0H##*&(C 	 		
rA   c                   V ^8  d   QhRR/# )r1   r:   r    r<   )r=   s   "r>   r?   r@   j   s     % %/ %rA   c                    ^RI Hp V! V 4      # )  The Task API executes web research and extraction tasks.

Clients submit a natural-language objective with an optional input schema; the service plans retrieval, fetches relevant URLs, and returns outputs that conform to a provided or inferred JSON schema. Supports deep research style queries and can return rich structured JSON outputs. Processors trade-off between cost, latency, and quality. Each processor supports calibrated confidences.
- Output metadata: citations, excerpts, reasoning, and confidence per field
)r    )resources.task_runr    )rR   r    s   & r>   r   Parallel.task_runi   s     	8t$$rA   c                   V ^8  d   QhRR/# )r1   r:   r"   r<   )r=   s   "r>   r?   r@   u   s     " "l "rA   c                	    ^RI Hp V! V 4      # )   )r"   )resources.betar"   )rR   r"   s   & r>   r   Parallel.betat   s    0D!!rA   c                   V ^8  d   QhRR/# )r1   r:   ParallelWithRawResponser<   )r=   s   "r>   r?   r@   {   s     - -#: -rA   c                	    \        V 4      # N)ra   rR   s   &r>   with_raw_responseParallel.with_raw_responsez   s    &t,,rA   c                   V ^8  d   QhRR/# )r1   r:   ParallelWithStreamedResponser<   )r=   s   "r>   r?   r@      s     2 2)E 2rA   c                	    \        V 4      # rc   )rh   rd   s   &r>   with_streaming_response Parallel.with_streaming_response~       +D11rA   c                   V ^8  d   QhRR/# r1   r:   r   r<   )r=   s   "r>   r?   r@           1 1K 1rA   c                	    \        R R7      # comma)array_formatr
   rd   s   &r>   qsParallel.qs        00rA   c                   V ^8  d   QhRR/# r1   r:   zdict[str, str]r<   )r=   s   "r>   r?   r@           & &n &rA   c                	"    V P                   pR V/# z	x-api-keyr(   rR   r(   s   & r>   auth_headersParallel.auth_headers        ,,W%%rA   c                   V ^8  d   QhRR/# r1   r:   zdict[str, str | Omit]r<   )r=   s   "r>   r?   r@           
 
!6 
rA   c                	<   < / \         SV `  CR R/CV P                  C# )X-Stainless-Asyncfalse)rO   r,   _custom_headersrR   rS   s   &r>   r,   Parallel.default_headers   s4    
g%

 ""
 	
rA   set_default_headersset_default_query_extra_kwargsc               D    V ^8  d   QhRRRRRRRRR	R
RRRRRRRRRRRR/# )r1   r(   r2   r)   r3   r*   r4   r.   r8   r+   int | NotGivenr,   r6   r   r-   r7   r   r   Mapping[str, Any]r:   r   r<   )r=   s   "r>   r?   r@      sz     -
 -
 -
 )	-

 3-
 )-
 $-
 2-
 6-
 3-
 7-
 )-
 
-
rA   c       
           Ve   Ve   \        R4      hVe   V	e   \        R4      hV P                  pVe   / VCVCpMVe   TpV P                  pVe   / VCVCpMV	e   T	pT;'       g    V P                  pV P                  ! R
RT;'       g    V P
                  RT;'       g    V P                  R\        V\        4      '       d   V P                  MTRTR\        V4      '       d   TMV P                  RVR	V/V
B # zn
Create a new client instance re-using the same options given to the current client with optional overriding.
zPThe `default_headers` and `set_default_headers` arguments are mutually exclusivezLThe `default_query` and `set_default_query` arguments are mutually exclusiver(   r)   r*   r.   r+   r,   r-   r<   
ValueErrorr   _custom_query_clientrS   r(   r)   
isinstancer   r*   r   r+   rR   r(   r)   r*   r.   r+   r,   r   r-   r   r   headersparamss   &$$$$$$$$$$  r>   copyParallel.copy   4   " &+>+Jopp$):)Fkll&&&44O4G ,)G##$00-0F*&F!11T\\~~ 	
++t||	
..	
 %/w$A$ADLLw	
 $		

 (0'<'<$BRBR	
 $	
 !	
 	
 		
rA   c               (    V ^8  d   QhRRRRRRRR/# 	r1   err_msgr'   bodyobjectresponsezhttpx.Responser:   r   r<   )r=   s   "r>   r?   r@      8     E EE 	E
 !E 
ErA   c               	   VP                   R 8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P
                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8  d   \        P                  ! WVR7      # \        WVR7      # 	i  )r   r   i  i  i  i  i  i  i  status_coder	   BadRequestErrorAuthenticationErrorPermissionDeniedErrorNotFoundErrorConflictErrorUnprocessableEntityErrorRateLimitErrorInternalServerErrorr   rR   r   r   r   s   &&$$r>   _make_status_errorParallel._make_status_error       3&..wPTUU3&227TXYY3&44WVZ[[3&,,WdSS3&,,WdSS3&77Y]^^3&--gtTT3&227TXYYgtDDrA   r|   __name__
__module____qualname____firstlineno____annotations__r   r   rP   r   r   r   re   rj   propertyr   rt   r~   r,   r   with_optionsr   __static_attributes____classcell__rS   s   @r>   r$   r$   2   s   L1
 #1
 ,0	1

 6?1
 /1
 591
 6:1
 ,01
* -2+1
 1
f % % " "
 - - 2 2 1  1 &  & 
  
-
 #-
 ,0	-

 6?-
 ,0-
 '0-
 59-
 9=-
 6:-
 :>-
 ,.-
b LE ErA   c                  n  a  ] tR t^t$ R]R&   RRRRR]R]RRRRR	RR
R/R V 3R lllt]R R l4       t	]R R l4       t
]R R l4       t]R R l4       t]]R R l4       4       t]]R R l4       4       t]]R V 3R ll4       4       tRRRRR]R	RR]RRRRRRRRR/ /
R R  llt]t]R! R" l4       tR#tV ;t# )$r%   r'   r(   Nr)   r*   r+   r,   r-   r.   r/   Fc               <    V ^8  d   QhRRRRRRRRR	R
RRRRRRRR/	# )r1   r(   r2   r)   r3   r*   r4   r+   r5   r,   r6   r-   r7   r.   httpx.AsyncClient | Noner/   r9   r:   r;   r<   )r=   s   "r>   r?   AsyncParallel.__annotate__   sf     1
 1
 1
 )	1

 31
 1
 21
 31
 .1
* &*+1
, 
-1
rA   c                  < Vf    \         P                  P                  R4      pVf   \        R4      hWn        Vf    \         P                  P                  R4      pVf   Rp\
        S	V `  \        VVVVVVVR7       R# )zConstruct a new async AsyncParallel client instance.

This automatically infers the `api_key` argument from the `PARALLEL_API_KEY` environment variable if it is not provided.
NrC   rD   rE   rF   rG   rK   rQ   s
   &$$$$$$$$r>   rP   AsyncParallel.__init__   rU   rA   c                   V ^8  d   QhRR/# )r1   r:   r!   r<   )r=   s   "r>   r?   r   #  s     * *. *rA   c                    ^RI Hp V! V 4      # )rX   )r!   )rY   r!   )rR   r!   s   & r>   r   AsyncParallel.task_run"  s     	=#D))rA   c                   V ^8  d   QhRR/# )r1   r:   r#   r<   )r=   s   "r>   r?   r   .  s     ' '' 'rA   c                	    ^RI Hp V! V 4      # )r]   )r#   )r^   r#   )rR   r#   s   & r>   r   AsyncParallel.beta-  s    5 &&rA   c                   V ^8  d   QhRR/# )r1   r:   AsyncParallelWithRawResponser<   )r=   s   "r>   r?   r   4  s     2 2#? 2rA   c                	    \        V 4      # rc   )r   rd   s   &r>   re   AsyncParallel.with_raw_response3  rl   rA   c                   V ^8  d   QhRR/# )r1   r:   !AsyncParallelWithStreamedResponser<   )r=   s   "r>   r?   r   8  s     7 7)J 7rA   c                	    \        V 4      # rc   )r   rd   s   &r>   rj   %AsyncParallel.with_streaming_response7  s    066rA   c                   V ^8  d   QhRR/# rn   r<   )r=   s   "r>   r?   r   =  ro   rA   c                	    \        R R7      # rq   r
   rd   s   &r>   rt   AsyncParallel.qs;  rv   rA   c                   V ^8  d   QhRR/# rx   r<   )r=   s   "r>   r?   r   B  ry   rA   c                	"    V P                   pR V/# r{   r|   r}   s   & r>   r~   AsyncParallel.auth_headers@  r   rA   c                   V ^8  d   QhRR/# r   r<   )r=   s   "r>   r?   r   H  r   rA   c                	R   < / \         SV `  CR R\        4        2/CV P                  C# )r   zasync:)rO   r,   r   r   r   s   &r>   r,   AsyncParallel.default_headersF  s@    
g%
6*;*=)>!?
 ""
 	
rA   r   r   r   c               D    V ^8  d   QhRRRRRRRRR	R
RRRRRRRRRRRR/# )r1   r(   r2   r)   r3   r*   r4   r.   r   r+   r   r,   r6   r   r-   r7   r   r   r   r:   r   r<   )r=   s   "r>   r?   r   O  sz     -
 -
 -
 )	-

 3-
 .-
 $-
 2-
 6-
 3-
 7-
 )-
 
-
rA   c       
           Ve   Ve   \        R4      hVe   V	e   \        R4      hV P                  pVe   / VCVCpMVe   TpV P                  pVe   / VCVCpMV	e   T	pT;'       g    V P                  pV P                  ! R
RT;'       g    V P
                  RT;'       g    V P                  R\        V\        4      '       d   V P                  MTRTR\        V4      '       d   TMV P                  RVR	V/V
B # r   r   r   s   &$$$$$$$$$$  r>   r   AsyncParallel.copyO  r   rA   c               (    V ^8  d   QhRRRRRRRR/# r   r<   )r=   s   "r>   r?   r     r   rA   c               	   VP                   R 8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P
                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8X  d   \        P                  ! WVR7      # VP                   R8  d   \        P                  ! WVR7      # \        WVR7      # r   r   r   s   &&$$r>   r    AsyncParallel._make_status_error  r   rA   r|   r   r   s   @r>   r%   r%      s   L1
 #1
 ,0	1

 6?1
 /1
 591
 6:1
 151
* -2+1
 1
f * * ' '
 2 2 7 7 1  1 &  & 
  
-
 #-
 ,0	-

 6?-
 15-
 '0-
 59-
 9=-
 6:-
 :>-
 ,.-
b LE ErA   c                  Z    ] tR tRt$ R]R&   R R lt]R R l4       t]R R	 l4       tR
t	R# )ra   i  r$   r   c                    V ^8  d   QhRRRR/# r1   clientr$   r:   r;   r<   )r=   s   "r>   r?   $ParallelWithRawResponse.__annotate__        x D rA   c                	    Wn         R # rc   r   rR   r   s   &&r>   rP    ParallelWithRawResponse.__init__      rA   c                   V ^8  d   QhRR/# )r1   r:   z'task_run.TaskRunResourceWithRawResponser<   )r=   s   "r>   r?   r     s     E EA ErA   c                F    ^RI Hp V! V P                  P                  4      # )rX   )TaskRunResourceWithRawResponse)rY   r   r   r   )rR   r   s   & r>   r    ParallelWithRawResponse.task_run  s     	G-dll.C.CDDrA   c                   V ^8  d   QhRR/# )r1   r:   z beta.BetaResourceWithRawResponser<   )r=   s   "r>   r?   r     s     > >6 >rA   c                	F    ^RI Hp V! V P                  P                  4      # )r]   )BetaResourceWithRawResponse)r^   r   r   r   )rR   r   s   & r>   r   ParallelWithRawResponse.beta  s    ?*4<<+<+<==rA   r   N
r   r   r   r   r   rP   r   r   r   r   r<   rA   r>   ra   ra     s7     E E > >rA   ra   c                  Z    ] tR tRt$ R]R&   R R lt]R R l4       t]R R	 l4       tR
t	R# )r   i  r%   r   c                    V ^8  d   QhRRRR/# r1   r   r%   r:   r;   r<   )r=   s   "r>   r?   )AsyncParallelWithRawResponse.__annotate__        }  rA   c                	    Wn         R # rc   r   r   s   &&r>   rP   %AsyncParallelWithRawResponse.__init__  r   rA   c                   V ^8  d   QhRR/# )r1   r:   z,task_run.AsyncTaskRunResourceWithRawResponser<   )r=   s   "r>   r?   r     s     J JF JrA   c                F    ^RI Hp V! V P                  P                  4      # )rX   )#AsyncTaskRunResourceWithRawResponse)rY   r   r   r   )rR   r   s   & r>   r   %AsyncParallelWithRawResponse.task_run  s     	L24<<3H3HIIrA   c                   V ^8  d   QhRR/# )r1   r:   z%beta.AsyncBetaResourceWithRawResponser<   )r=   s   "r>   r?   r     s     C C; CrA   c                	F    ^RI Hp V! V P                  P                  4      # )r]   ) AsyncBetaResourceWithRawResponse)r^   r  r   r   )rR   r  s   & r>   r   !AsyncParallelWithRawResponse.beta  s    D/0A0ABBrA   r   Nr   r<   rA   r>   r   r     s9     J J C CrA   r   c                  Z    ] tR tRt$ R]R&   R R lt]R R l4       t]R R	 l4       tR
t	R# )rh   i  r$   r   c                    V ^8  d   QhRRRR/# r   r<   )r=   s   "r>   r?   )ParallelWithStreamedResponse.__annotate__  r   rA   c                	    Wn         R # rc   r   r   s   &&r>   rP   %ParallelWithStreamedResponse.__init__  r   rA   c                   V ^8  d   QhRR/# )r1   r:   z-task_run.TaskRunResourceWithStreamingResponser<   )r=   s   "r>   r?   r    s     K KG KrA   c                F    ^RI Hp V! V P                  P                  4      # )rX   )$TaskRunResourceWithStreamingResponse)rY   r  r   r   )rR   r  s   & r>   r   %ParallelWithStreamedResponse.task_run  s     	M3DLL4I4IJJrA   c                   V ^8  d   QhRR/# )r1   r:   z&beta.BetaResourceWithStreamingResponser<   )r=   s   "r>   r?   r    s     D D< DrA   c                	F    ^RI Hp V! V P                  P                  4      # )r]   )!BetaResourceWithStreamingResponse)r^   r  r   r   )rR   r  s   & r>   r   !ParallelWithStreamedResponse.beta  s    E01B1BCCrA   r   Nr   r<   rA   r>   rh   rh     s9     K K D DrA   rh   c                  Z    ] tR tRt$ R]R&   R R lt]R R l4       t]R R	 l4       tR
t	R# )r   i  r%   r   c                    V ^8  d   QhRRRR/# r   r<   )r=   s   "r>   r?   .AsyncParallelWithStreamedResponse.__annotate__  r   rA   c                	    Wn         R # rc   r   r   s   &&r>   rP   *AsyncParallelWithStreamedResponse.__init__  r   rA   c                   V ^8  d   QhRR/# )r1   r:   z2task_run.AsyncTaskRunResourceWithStreamingResponser<   )r=   s   "r>   r?   r    s     P PL PrA   c                F    ^RI Hp V! V P                  P                  4      # )rX   ))AsyncTaskRunResourceWithStreamingResponse)rY   r  r   r   )rR   r  s   & r>   r   *AsyncParallelWithStreamedResponse.task_run  s     	R89N9NOOrA   c                   V ^8  d   QhRR/# )r1   r:   z+beta.AsyncBetaResourceWithStreamingResponser<   )r=   s   "r>   r?   r    s     I IA IrA   c                	F    ^RI Hp V! V P                  P                  4      # )r]   )&AsyncBetaResourceWithStreamingResponse)r^   r  r   r   )rR   r  s   & r>   r   &AsyncParallelWithStreamedResponse.beta  s    J5dll6G6GHHrA   r   Nr   r<   rA   r>   r   r     s9     P P I IrA   r   )r   r   r   r   r$   r%   ClientAsyncClient)9
__future__r   rL   typingr   r   r   typing_extensionsr   r   httpx r	   _qsr   _typesr   r   r   r   r   r   r   _utilsr   r   _compatr   _versionr   
_streamingr   r   r   r   _base_clientr   r   r   	resourcesr   r   rY   r    r!   resources.beta.betar"   r#   __all__r$   r%   ra   r   rh   r   r  r   r<   rA   r>   <module>r0     s    # 	 . . ,      0 $ ! D 6  )ID	vE} vErvEN vEr> >0C C0D D0I I0 
rA   