0j }"ddlmZddlmZmZddlmZddlmZddl Z ddl m Z m Z m Z mZmZmZdd lmZmZmZmZmZmZmZmZdd lmZmZmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'dd l(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6ddl7m8Z8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAddlBmCZCddlDmEZEddlFmGZGddgZHGdde0ZIGdde1ZJGddZKGddZLGd d!ZMGd"d#ZNdS)$) annotations)ListOptional)chain)LiteralN)FindAllResourceAsyncFindAllResourceFindAllResourceWithRawResponse#AsyncFindAllResourceWithRawResponse$FindAllResourceWithStreamingResponse)AsyncFindAllResourceWithStreamingResponse)BodyOmitQueryHeadersNotGivenSequenceNotStromit not_given)is_givenmaybe_transformstrip_not_givenasync_maybe_transform)TaskRunResourceAsyncTaskRunResourceTaskRunResourceWithRawResponse#AsyncTaskRunResourceWithRawResponse$TaskRunResourceWithStreamingResponse)AsyncTaskRunResourceWithStreamingResponse)cached_property)TaskGroupResourceAsyncTaskGroupResource TaskGroupResourceWithRawResponse%AsyncTaskGroupResourceWithRawResponse&TaskGroupResourceWithStreamingResponse+AsyncTaskGroupResourceWithStreamingResponse)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)beta_search_paramsbeta_extract_params)make_request_options) SearchResult)ExtractResponse)FetchPolicyParam)ParallelBetaParam)ExcerptSettingsParam) SourcePolicy BetaResourceAsyncBetaResourceceZdZed3dZed4dZed5dZed6d Zed7d Ze e e e e e d d d e d d8d%Z e e e e e e e e e e d d d e d&d9d2Z d S):r8returnrc*t|jSa 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_clientselfs d/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/parallel/resources/beta/beta.pytask_runzBetaResource.task_run:st|,,,r#c*t|jSa The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling. - Submit hundreds or thousands of Tasks as a single group - Observe group progress and receive results as they complete - Real-time updates via Server-Sent Events (SSE) - Add tasks to an existing group while it is running - Group-level retry and error aggregation Status: beta and subject to change. )r#r>r?s rA task_groupzBetaResource.task_groupCs!...rCr c*t|jSa 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. )r r>r?s rAfindallzBetaResource.findallPs t|,,,rCBetaResourceWithRawResponsec t|Sa 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 )rJr?s rAwith_raw_responsezBetaResource.with_raw_responseWs+4000rC!BetaResourceWithStreamingResponsec t|Sz 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 )rNr?s rAwith_streaming_responsez$BetaResource.with_streaming_responseas1666rCN excerpts fetch_policy full_content objectivesearch_queriesbetas extra_headers extra_query extra_bodytimeouturlsSequenceNotStr[str]rS#beta_extract_params.Excerpts | OmitrT!Optional[FetchPolicyParam] | OmitrU&beta_extract_params.FullContent | OmitrVOptional[str] | OmitrW$Optional[SequenceNotStr[str]] | OmitrXList[ParallelBetaParam] | OmitrYHeaders | NonerZ Query | Noner[ Body | Noner\'float | httpx.Timeout | None | NotGivenr3c `itdt|r.dtd|Ddgnti|pi}ddi|pi}|dt ||||||dtjt|| | | tS)  Extracts relevant content from specific web URLs. To access this endpoint, pass the `parallel-beta` header with the value `search-extract-2025-10-10`. Args: excerpts: Include excerpts from each URL relevant to the search objective and queries. Note that if neither objective nor search_queries is provided, excerpts are redundant with full content. fetch_policy: Policy for live fetching web results. full_content: Include full content from each URL. Note that if neither objective nor search_queries is provided, excerpts are redundant with full content. objective: If provided, focuses extracted content on the specified search objective. search_queries: If provided, focuses extracted content on the specified keyword search queries. 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,c34K|]}t|VdSNstr.0es rA z'BetaResource.extract..(4K4KSVV4K4K4K4K4K4KrCsearch-extract-2025-10-10/v1beta/extractr]rSrTrUrVrWrYrZr[r\bodyoptionscast_to) rrjoinrr_postrr0BetaExtractParamsr1r3 r@r]rSrTrUrVrWrXrYrZr[r\s rAextractzBetaResource.extractjs^  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ zz   ($0$0!*&4 $5  )+Q[el$!   rCrSrTmax_chars_per_result max_resultsmoderV processorrW source_policyrXrYrZr[r\ExcerptSettingsParam | OmitrOptional[int] | Omitrr7Optional[Literal['one-shot', 'agentic', 'fast']] | Omitr'Optional[Literal['base', 'pro']] | OmitrOptional[SourcePolicy] | Omitr2cfitdt| r.dtd| Ddgnti| pi} ddi| pi} |dt ||||||||| d tjt| | | |tS) i Searches the web. Args: excerpts: Optional settings to configure excerpt generation. fetch_policy: Policy for live fetching web results. max_chars_per_result: DEPRECATED: Use `excerpts.max_chars_per_result` instead. max_results: Upper bound on the number of results to return. Defaults to 10 if not provided. mode: Presets default values for parameters for different use cases. - `one-shot` returns more comprehensive results and longer excerpts to answer questions from a single response - `agentic` returns more concise, token-efficient results for use in an agentic loop - `fast` trades some quality for lower latency, with best results when used with concise and high-quality objective and keyword queries objective: Natural-language description of what the web search is trying to find. May include guidance about preferred sources or freshness. At least one of objective or search_queries must be provided. processor: DEPRECATED: use `mode` instead. search_queries: Optional list of traditional keyword search queries to guide the search. May contain search operators. At least one of objective or search_queries must be provided. source_policy: Source policy for web search results. This policy governs which sources are allowed/disallowed in results. 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 rkrlc34K|]}t|VdSrnrorqs rArtz&BetaResource.search..rurCrv/v1beta/search rSrTrrrrVrrWrryrz) rrr~rrrrr/BetaSearchParamsr1r2r@rSrTrrrrVrrWrrXrYrZr[r\s rAsearchzBetaResource.searchsB  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ zz  ($0,@#. !*!*&4%2  #3  )+Q[el!'   rC)r;r)r;r#)r;r )r;rJ)r;rNr]r^rSr_rTr`rUrarVrbrWrcrXrdrYrerZrfr[rgr\rhr;r3rSrrTr`rrrrrrrVrbrrrWrcrrrXrdrYrerZrfr[rgr\rhr;r2 __name__ __module__ __qualname__r"rBrFrIrMrQrrrrrCrAr8r89sM---_- / / /_ /---_- 111_1777_79=:>?C*.?C04)-$("&;DK K K K K K `15:>59,0HL*.=A?C7;04)-$("&;D%` ` ` ` ` ` ` ` rCceZdZed3dZed4dZed5dZed6d Zed7d Ze e e e e e d d d e d d8d%Z e e e e e e e e e e d d d e d&d9d2Z d S):r9r;rc*t|jSr=)rr>r?s rArBzAsyncBetaResource.task_runs$DL111rCr$c*t|jSrE)r$r>r?s rArFzAsyncBetaResource.task_group$s&dl333rCr c*t|jSrH)r r>r?s rArIzAsyncBetaResource.findall1s $DL111rC AsyncBetaResourceWithRawResponsec t|SrL)rr?s rArMz#AsyncBetaResource.with_raw_response8s0555rC&AsyncBetaResourceWithStreamingResponsec t|SrP)rr?s rArQz)AsyncBetaResource.with_streaming_responseBs6d;;;rCNrRr]r^rSr_rTr`rUrarVrbrWrcrXrdrYrerZrfr[rgr\rhr3c |Kitdt|r.dtd|Ddgnti|pi}ddi|pi}|dt ||||||dtjd{Vt|| | | t d{VS) rjrkrlc34K|]}t|VdSrnrorqs rArtz,AsyncBetaResource.extract..}rurCrvrwrxNryrz) rrr~rrrrr0rr1r3rs rArzAsyncBetaResource.extractKs=^  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ ZZ , ($0$0!*&4 $5        )+Q[el$!          rCrrrrrrrrrrrr2cKitdt| r.dtd| Ddgnti| pi} ddi| pi} |dt ||||||||| d tjd{Vt| | | |t d{VS) rrkrlc34K|]}t|VdSrnrorqs rArtz+AsyncBetaResource.search..rurCrvrrNryrz) rrr~rrrrr/rr1r2rs rArzAsyncBetaResource.searchsFB  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ ZZ , ($0,@#. !*!*&4%2  #3        )+Q[el!'          rC)r;r)r;r$)r;r )r;r)r;rrrrrrCrAr9r9sM222_2 4 4 4_ 4222_2 666_6<<<_<9=:>?C*.?C04)-$("&;DK K K K K K `15:>59,0HL*.=A?C7;04)-$("&;D%` ` ` ` ` ` ` ` rCc^eZdZd dZeddZedd Zedd Zd S)rJbetar8r;Nonecx||_t|j|_t|j|_dSrn)_betar+rrr@rs rA__init__z$BetaResourceWithRawResponse.__init__s; . L   . K   rCrc4t|jjSr=)rrrBr?s rArBz$BetaResourceWithRawResponse.task_runs.dj.ABBBrCr%c4t|jjSrE)r%rrFr?s rArFz&BetaResourceWithRawResponse.task_groups0 0EFFFrCr c4t|jjSrH)r rrIr?s rArIz#BetaResourceWithRawResponse.findalls .dj.@AAArCNrr8r;r)r;r)r;r%)r;r rrrrr"rBrFrIrrCrArJrJs    CCC_C G G G_ GBBB_BBBrCrJc^eZdZd dZeddZedd Zedd Zd S)rrr9r;rcx||_t|j|_t|j|_dSrn)rr-rrrs rArz)AsyncBetaResourceWithRawResponse.__init__%s; 4 L   4 K   rCrc4t|jjSr=)rrrBr?s rArBz)AsyncBetaResourceWithRawResponse.task_run/s34:3FGGGrCr&c4t|jjSrE)r&rrFr?s rArFz+AsyncBetaResourceWithRawResponse.task_group8s5TZ5JKKKrCr c4t|jjSrH)r rrIr?s rArIz(AsyncBetaResourceWithRawResponse.findallEs 34:3EFFFrCNrr9r;r)r;r)r;r&)r;r rrrCrArr$s    HHH_H L L L_ LGGG_GGGrCrc^eZdZd dZeddZedd Zedd Zd S)rNrr8r;rcx||_t|j|_t|j|_dSrn)rr,rrrs rArz*BetaResourceWithStreamingResponse.__init__Ns; 3 L   3 K   rCr c4t|jjSr=)r rrBr?s rArBz*BetaResourceWithStreamingResponse.task_runXs4DJ4GHHHrCr'c4t|jjSrE)r'rrFr?s rArFz,BetaResourceWithStreamingResponse.task_groupas6dj6KLLLrCr c4t|jjSrH)r rrIr?s rArIz)BetaResourceWithStreamingResponse.findallns 4DJ4FGGGrCNr)r;r )r;r')r;r rrrCrArNrNMs    III_I M M M_ MHHH_HHHrCrNc^eZdZd dZeddZedd Zedd Zd S)rrr9r;rcx||_t|j|_t|j|_dSrn)rr.rrrs rArz/AsyncBetaResourceWithStreamingResponse.__init__ws; 9 L   9 K   rCr!c4t|jjSr=)r!rrBr?s rArBz/AsyncBetaResourceWithStreamingResponse.task_runs99LMMMrCr(c4t|jjSrE)r(rrFr?s rArFz1AsyncBetaResourceWithStreamingResponse.task_groups;4:;PQQQrCrc4t|jjSrH)rrrIr?s rArIz.AsyncBetaResourceWithStreamingResponse.findalls 99KLLLrCNr)r;r!)r;r()r;rrrrCrArrvs    NNN_N R R R_ RMMM_MMMrCr)O __future__rtypingrr itertoolsrtyping_extensionsrhttpxrIr r r r r r_typesrrrrrrrr_utilsrrrrrBrrrrr r!_compatr"rFr#r$r%r&r'r( _resourcer)r* _responser+r,r-r. types.betar/r0 _base_clientr1types.beta.search_resultr2types.beta.extract_responser3types.beta.fetch_policy_paramr4types.beta.parallel_beta_paramr5!types.beta.excerpt_settings_paramr6!types.shared_params.source_policyr7__all__r8r9rJrrNrrrCrArs#"""""!!!!!!!!%%%%%% \[[[[[[[[[[[[[[[[[[[WWWWWWWWWWWW'&&&&&;::::::: BAAAAAAA000000444444::::::======??????EEEEEE====== . /^ ^ ^ ^ ^ ?^ ^ ^ B^ ^ ^ ^ ^ (^ ^ ^ B&B&B&B&B&B&B&B&BR&G&G&G&G&G&G&G&GR&H&H&H&H&H&H&H&HR&M&M&M&M&M&M&M&M&M&MrC