_j]RSSKJr SSKrSSKJrJrJrJr SSKJ r J r J r SSK r SSK Jr SSKJr SSKJrJr SS KJrJrJrJrJrJrJrJrJrJrJrJ r SS K!J"r"J#r#J$r$J%r%J&r& SS K'J(r( SS K)J*r* SS K+J,r,J-r-J.r.J/r/ SSK0J1r1J2r2 SSKJ3r3J4r4 SSK5J6r6J7r7J8r8J9r9 SSK:J;r; SSKJ?r? SSK@JArA \(a,SSKBJCrCJDrDJErEJFrF SSKGJHrHJIrI SSKJJKrKJLrL SSKMJNrNJOrO SSKPJQrQJRrR /SQrS"SS\75rT"SS\85rU"SS 5rV"S!S"5rW"S#S$5rX"S%S&5rY\TrZ\Ur[g)') annotationsN) TYPE_CHECKINGAnyMappingOptional)SelfLiteraloverride) _exceptions Querystring)client_search_paramsclient_extract_params) BodyOmitQueryHeadersTimeoutNotGiven Transport ProxiesTypesRequestOptionsSequenceNotStromit not_given)is_given is_mapping_tmaybe_transformget_async_libraryasync_maybe_transform)cached_property) __version__)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream) ParallelErrorAPIStatusError)DEFAULT_MAX_RETRIES SyncAPIClientAsyncAPIClientmake_request_options) SearchResult)ExtractResponse)AdvancedSearchSettingsParam)AdvancedExtractSettingsParam)betamonitortask_run task_group)MonitorResourceAsyncMonitorResource)TaskRunResourceAsyncTaskRunResource) BetaResourceAsyncBetaResource)TaskGroupResourceAsyncTaskGroupResource)rrrrParallel AsyncParallelClient AsyncClientc b^\rSrSr%S\S'SS\\SSSSS.SU4Sjjjr\SSj5r \SS j5r \SS j5r \SS j5r \SS j5r \SS j5r\\S Sj55r\\S!Sj55r\\S"U4Sjj55rSS\S\SSSS0S. S#Sjjr\r\\\\\\SSS\S. S$Sjjr\\\\\\SSS\S. S%Sjjr\S&Sj5rSrU=r$)'r@Kstrapi_keyNFrGbase_urltimeout max_retriesdefault_headers default_query http_client_strict_response_validationc >Uc[RRS5nUc [S5eXlUc[RRS5nUcSn[RRS5n U bs0n U R S5HDn U R S5n U S :dMXS -SR5XSU R5'MF 0U E[U5(aUO0En[T U])[UUUUUUUS 9 g) 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. NPARALLEL_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 variablePARALLEL_BASE_URLhttps://api.parallel.aiPARALLEL_CUSTOM_HEADERS :rr versionrIrKrJrNcustom_headers custom_queryrO osenvirongetr*rGsplitfindstriprsuper__init__r#selfrGrIrJrKrLrMrNrOcustom_headers_envparsedlinecolon __class__s E/home/rurouni/.local/lib/python3.13/site-packages/parallel/_client.pyrdParallel.__init__O6 ?jjnn%78G ?X   zz~~&9:H  0HZZ^^,EF  )%'F*006 #A:37 3D3J3J3LF<--/07gf|O?\?\ObdfO ##*&(C  cSSKJn U"U5$)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 Task Groups enable 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 r )r:)resources.task_runr:)rfr:s rlr6Parallel.task_runs 8t$$rocSSKJn U"U5$)rqr )r>)resources.task_groupr>)rfr>s rlr7Parallel.task_groups < &&rocSSKJn U"U5$)The Monitor API watches the web for material changes on a fixed frequency. Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. - `event_stream` monitors track a search query and emit an event for each new material change. - `snapshot` monitors track a specific task run's output and emit an event when the output changes. Results can be polled via the events endpoint or delivered via webhooks. r )r8)resources.monitorr8)rfr8s rlr5Parallel.monitors 7t$$rocSSKJn U"U5$)Nr )r<)resources.betar<)rfr<s rlr4 Parallel.betas0D!!roc[U5$N)ParallelWithRawResponserfs rlwith_raw_responseParallel.with_raw_responses &t,,roc[U5$r)ParallelWithStreamedResponsers rlwith_streaming_response Parallel.with_streaming_response +D11roc[SS9$Ncomma) array_formatr rs rlqs Parallel.qs00roc"URnSU0$Nz x-api-keyrGrfrGs rl auth_headersParallel.auth_headers,,W%%roc<>0[TU]ESS0EURE$)NX-Stainless-Asyncfalse)rcrL_custom_headersrfrks rlrLParallel.default_headerss4 g%  ""  ro rGrIrJrNrKrLset_default_headersrMset_default_query _extra_kwargsc UbUb [S5eUbU b [S5eURn Ub0U EUEn OUbUn URn Ub0U EUEn OU bU n U=(d URnUR"SU=(d UR U=(d UR [U[5(a UROUU[U5(aUO URU U S.U D6$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 exclusive)rGrIrJrNrKrLrM ValueErrorr _custom_query_clientrkrGrI isinstancerrJrrK rfrGrIrJrNrKrLrrMrrheadersparamss rlcopy Parallel.copy"  &+>+Jop p  $):)Fkl l&&  &44O4G ,)G##  $00-0F  *&F!1T\\ ~~  +t||.$.w$A$ADLLw#'/ '<'< $BRBR#     ro advanced_settings client_modelmax_chars_total objectivesearch_queries session_id extra_headers extra_query extra_bodyrJc ~URS[UUUUUUUS.[R5[ XXS9[ S9$) Extracts relevant content from specific web URLs. The legacy Extract API reference (`/v1beta/extract` endpoint) is available [here](https://docs.parallel.ai/api-reference/legacy/extract-beta/extract), and migration guide is [here](https://docs.parallel.ai/extract/extract-migration-guide). Args: urls: URLs to extract content from. Up to 20 URLs. advanced_settings: Advanced extract configuration. These settings may impact result quality and latency unless used carefully. See https://docs.parallel.ai/search/advanced-extract-settings for more info. client_model: The model generating this request and consuming the results. Enables optimizations and tailors default settings for the model's capabilities. max_chars_total: Upper bound on total characters across excerpts from all extracted results. objective: As in SearchRequest, a natural-language description of the underlying question or goal driving the request. Used together with search_queries to focus excerpts on the most relevant content. search_queries: Optional keyword search queries, as in SearchRequest. Used together with objective to focus excerpts on the most relevant content. session_id: Session identifier to track calls across separate search and extract calls, to be used as part of a larger task. Specifying it may give better contextual results for subsequent API calls. 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 /v1/extracturlsrrrrrrrrrrJbodyoptionscast_to)postrrClientExtractParamsr/r1 rfrrrrrrrrrrrJs rlextractParallel.extracts`ryy   ):$0'6!*&4",&99 )+Q[$#  ro rrrmoderrrrrrJc ~URS[UUUUUUUS.[R5[ XXS9[ S9$) Searches the web. The legacy Search API reference (`/v1beta/search` endpoint) is available [here](https://docs.parallel.ai/api-reference/legacy/search-beta/search), and migration guide is [here](https://docs.parallel.ai/search/search-migration-guide). Args: search_queries: Concise keyword search queries, 3-6 words each. At least one query is required, provide 2-3 for best results. Used together with objective to focus results on the most relevant content. advanced_settings: Advanced search configuration. These settings may impact result quality and latency unless used carefully. See https://docs.parallel.ai/search/advanced-search-settings for more info. client_model: The model generating this request and consuming the results. Enables optimizations and tailors default settings for the model's capabilities. max_chars_total: Upper bound on total characters across excerpts from all results. mode: Search mode preset: supported values are `basic` and `advanced`. Basic mode offers the lowest latency and works best with 2-3 high-quality search_queries. Advanced mode provides higher quality with more advanced retrieval and compression. Defaults to `advanced` when omitted. objective: Natural-language description of the underlying question or goal driving the search. Used together with search_queries to focus results on the most relevant content. Should be self-contained with enough context to understand the intent of the search. session_id: Session identifier to track calls across separate search and extract calls, to be used as part of a larger task. Specifying it may give better contextual results for subsequent API calls. 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 /v1/searchrrrrrrrrr)rrrClientSearchParamsr/r0 rfrrrrrrrrrrrJs rlsearchParallel.search_s`|yy  &4):$0'6 !*",%77 )+Q[!#  rocfURS:Xa[R"XUS9$URS:Xa[R"XUS9$URS:Xa[R"XUS9$URS:Xa[R "XUS9$URS:Xa[R "XUS9$URS:Xa[R"XUS9$URS:Xa[R"XUS9$URS :a[R"XUS9$[XUS9$ Ni)responseriiiiiii status_coder BadRequestErrorAuthenticationErrorPermissionDeniedError NotFoundError ConflictErrorUnprocessableEntityErrorRateLimitErrorInternalServerErrorr+rferr_msgrrs rl_make_status_errorParallel._make_status_error   3 &..wPTU U   3 &227TXY Y   3 &44WVZ[ [   3 &,,WdS S   3 &,,WdS S   3 &77Y]^ ^   3 &--gtT T   3 &227TXY YgtDDror)rG str | NonerIstr | httpx.URL | NonerJ!float | Timeout | None | NotGivenrKintrLMapping[str, str] | NonerMMapping[str, object] | NonerNhttpx.Client | NonerOboolreturnNone)rr:)rr>)rr8)rr<)rr)rrrrrzdict[str, str]rzdict[str, str | Omit])rGrrIrrJrrNrrKint | NotGivenrLrrrrMrrrrMapping[str, Any]rrrSequenceNotStr[str]rz-Optional[AdvancedExtractSettingsParam] | OmitrOptional[str] | OmitrOptional[int] | Omitrrrz$Optional[SequenceNotStr[str]] | OmitrrrHeaders | Noner Query | Noner Body | NonerJ'float | httpx.Timeout | None | NotGivenrr1rrrz,Optional[AdvancedSearchSettingsParam] | Omitrrrrrz-Optional[Literal['basic', 'advanced']] | OmitrrrrrrrrrrrJrrr0rrFrobjectrzhttpx.Responserr+__name__ __module__ __qualname____firstlineno____annotations__rr,rdr"r6r7r5r4rrpropertyr rrrLr with_optionsrrrr__static_attributes__ __classcell__rks@rlr@r@Ks L #+/5>.4859,0-2+: : ) : 3 :  : 2: 3: ): *&*+: , -: : x%%"''" % %"" --22 11 &&   #+/5>+/&/488<599=+-- - ) - 3 - ) - $- 2- 6- 3- 7- )-  - bL LP-104*.?C+/)-$("&;DK "K I K + K . K (K =K )K &K "K  K 9K !K bKO-104>B*.+/)-$("&;DP ,P H P + P . P <P (P )P &P "P  P 9P !P dEE E ! E  EEror@c b^\rSrSr%S\S'SS\\SSSSS.SU4Sjjjr\SSj5r \SS j5r \SS j5r \SS j5r \SS j5r \SS j5r\\S Sj55r\\S!Sj55r\\S"U4Sjj55rSS\S\SSSS0S. S#Sjjr\r\\\\\\SSS\S. S$Sjjr\\\\\\SSS\S. S%Sjjr\S&Sj5rSrU=r$)'rAirFrGNFrHc >Uc[RRS5nUc [S5eXlUc[RRS5nUcSn[RRS5n U bs0n U R S5HDn U R S5n U S :dMXS -SR5XSU R5'MF 0U E[U5(aUO0En[T U])[UUUUUUUS 9 g) 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. NrQrRrSrTrUrVrWrr rXr\res rlrdAsyncParallel.__init__rnrocSSKJn U"U5$)rqr )r;)rrr;)rfr;s rlr6AsyncParallel.task_runs =#D))rocSSKJn U"U5$)rqr )r?)rur?)rfr?s rlr7AsyncParallel.task_group%s A%d++rocSSKJn U"U5$)rxr )r9)ryr9)rfr9s rlr5AsyncParallel.monitor7s <#D))rocSSKJn U"U5$)Nr )r=)r|r=)rfr=s rlr4AsyncParallel.betaEs5 &&roc[U5$r)AsyncParallelWithRawResponsers rlrAsyncParallel.with_raw_responseKrroc[U5$r)!AsyncParallelWithStreamedResponsers rlr%AsyncParallel.with_streaming_responseOs 066roc[SS9$rr rs rlrAsyncParallel.qsSrroc"URnSU0$rrrs rlrAsyncParallel.auth_headersXrrocR>0[TU]ESS[530EURE$)Nrzasync:)rcrLr rrs rlrLAsyncParallel.default_headers^s@ g% 6*;*=)>!? ""  rorc UbUb [S5eUbU b [S5eURn Ub0U EUEn OUbUn URn Ub0U EUEn OU bU n U=(d URnUR"SU=(d UR U=(d UR [U[5(a UROUU[U5(aUO URU U S.U D6$rrrs rlrAsyncParallel.copygrrorc # URS[UUUUUUUS.[R5IShvN [ XXS9[ S9IShvN $NN7f)rrrNrr)rr!rrr/r1rs rlrAsyncParallel.extractswrYY , ):$0'6!*&4",&99  )+Q[$#     !2AA A A AArc # URS[UUUUUUUS.[R5IShvN [ XXS9[ S9IShvN $NN7f)rrrNrr)rr!rrr/r0rs rlrAsyncParallel.searchsw|YY ,&4):$0'6 !*",%77  )+Q[!#     r$cfURS:Xa[R"XUS9$URS:Xa[R"XUS9$URS:Xa[R"XUS9$URS:Xa[R "XUS9$URS:Xa[R "XUS9$URS:Xa[R"XUS9$URS:Xa[R"XUS9$URS :a[R"XUS9$[XUS9$rrrs rlr AsyncParallel._make_status_error9rror)rGrrIrrJrrKrrLrrMrrNhttpx.AsyncClient | NonerOrrr)rr;)rr?)rr9)rr=)rr)rrrrr)rGrrIrrJrrNr)rKrrLrrrrMrrrrrrrrrrrrs@rlrArAs L #+/5>.485915-2+: : ) : 3 :  : 2: 3: .: *&*+: , -: : x**",," * *'' 2277 11 &&   #+/5>04&/488<599=+-- - ) - 3 - . - $- 2- 6- 3- 7- )-  - bL LP-104*.?C+/)-$("&;DK "K I K + K . K (K =K )K &K "K  K 9K !K bKO-104>B*.+/)-$("&;DP ,P H P + P . P <P (P )P &P "P  P 9P !P dEE E ! E  EErorAcz\rSrSr%S\S'S Sjr\S Sj5r\S Sj5r\SSj5r \SSj5r S r g )ri[r@rcxXl[UR5Ul[UR5Ulgr)rr$rrrfclients rlrd ParallelWithRawResponse.__init__^s/ . NN  . MM  rocFSSKJn U"URR5$)rqr )TaskRunResourceWithRawResponse)rrr0rr6)rfr0s rlr6 ParallelWithRawResponse.task_runhs G-dll.C.CDDrocFSSKJn U"URR5$)rqr ) TaskGroupResourceWithRawResponse)rur3rr7)rfr3s rlr7"ParallelWithRawResponse.task_groupzs K/ 0G0GHHrocFSSKJn U"URR5$)rxr )MonitorResourceWithRawResponse)ryr6rr5)rfr6s rlr5ParallelWithRawResponse.monitors F-dll.B.BCCrocFSSKJn U"URR5$)Nr )BetaResourceWithRawResponse)r|r9rr4)rfr9s rlr4ParallelWithRawResponse.betas?*4<<+<+<==rorrrNr-r@rr)rz'task_run.TaskRunResourceWithRawResponse)rz+task_group.TaskGroupResourceWithRawResponse)rz&monitor.MonitorResourceWithRawResponse)rz beta.BetaResourceWithRawResponse rrrrrrdr"r6r7r5r4rrrorlrr[sc  EE"II" D D>>rorcz\rSrSr%S\S'S Sjr\S Sj5r\S Sj5r\SSj5r \SSj5r S r g )rirArcxXl[UR5Ul[UR5Ulgr)rr&rrr,s rlrd%AsyncParallelWithRawResponse.__init__s/ 4 NN  4 MM  rocFSSKJn U"URR5$)rqr )#AsyncTaskRunResourceWithRawResponse)rrrBrr6)rfrBs rlr6%AsyncParallelWithRawResponse.task_runs L24<<3H3HIIrocFSSKJn U"URR5$)rqr )%AsyncTaskGroupResourceWithRawResponse)rurErr7)rfrEs rlr7'AsyncParallelWithRawResponse.task_groups P4T\\5L5LMMrocFSSKJn U"URR5$)rxr )#AsyncMonitorResourceWithRawResponse)ryrHrr5)rfrHs rlr5$AsyncParallelWithRawResponse.monitors K24<<3G3GHHrocFSSKJn U"URR5$)Nr ) AsyncBetaResourceWithRawResponse)r|rKrr4)rfrKs rlr4!AsyncParallelWithRawResponse.betasD/ 0A0ABBror;Nr-rArr)rz,task_run.AsyncTaskRunResourceWithRawResponse)rz0task_group.AsyncTaskGroupResourceWithRawResponse)rz+monitor.AsyncMonitorResourceWithRawResponse)rz%beta.AsyncBetaResourceWithRawResponser=rrorlrrse  JJ"NN" I ICCrorcz\rSrSr%S\S'S Sjr\S Sj5r\S Sj5r\SSj5r \SSj5r S r g )rir@rcxXl[UR5Ul[UR5Ulgr)rr%rrr,s rlrd%ParallelWithStreamedResponse.__init__s/ 3 NN  3 MM  rocFSSKJn U"URR5$)rqr )$TaskRunResourceWithStreamingResponse)rrrRrr6)rfrRs rlr6%ParallelWithStreamedResponse.task_runs M3DLL4I4IJJrocFSSKJn U"URR5$)rqr )&TaskGroupResourceWithStreamingResponse)rurUrr7)rfrUs rlr7'ParallelWithStreamedResponse.task_groups Q5dll6M6MNNrocFSSKJn U"URR5$)rxr )$MonitorResourceWithStreamingResponse)ryrXrr5)rfrXs rlr5$ParallelWithStreamedResponse.monitors L3DLL4H4HIIrocFSSKJn U"URR5$)Nr )!BetaResourceWithStreamingResponse)r|r[rr4)rfr[s rlr4!ParallelWithStreamedResponse.beta&sE01B1BCCror;Nr<)rz-task_run.TaskRunResourceWithStreamingResponse)rz1task_group.TaskGroupResourceWithStreamingResponse)rz,monitor.MonitorResourceWithStreamingResponse)rz&beta.BetaResourceWithStreamingResponser=rrorlrrse  KK"OO" J JDDrorcz\rSrSr%S\S'S Sjr\S Sj5r\S Sj5r\SSj5r \SSj5r S r g )ri-rArcxXl[UR5Ul[UR5Ulgr)rr'rrr,s rlrd*AsyncParallelWithStreamedResponse.__init__0s/ 9 NN  9 MM  rocFSSKJn U"URR5$)rqr ))AsyncTaskRunResourceWithStreamingResponse)rrrarr6)rfras rlr6*AsyncParallelWithStreamedResponse.task_run:s R89N9NOOrocFSSKJn U"URR5$)rqr )+AsyncTaskGroupResourceWithStreamingResponse)rurdrr7)rfrds rlr7,AsyncParallelWithStreamedResponse.task_groupLs V:4<<;R;RSSrocFSSKJn U"URR5$)rxr ))AsyncMonitorResourceWithStreamingResponse)ryrgrr5)rfrgs rlr5)AsyncParallelWithStreamedResponse.monitor^s Q89M9MNNrocFSSKJn U"URR5$)Nr )&AsyncBetaResourceWithStreamingResponse)r|rjrr4)rfrjs rlr4&AsyncParallelWithStreamedResponse.betalsJ5dll6G6GHHror;NrM)rz2task_run.AsyncTaskRunResourceWithStreamingResponse)rz6task_group.AsyncTaskGroupResourceWithStreamingResponse)rz1monitor.AsyncMonitorResourceWithStreamingResponse)rz+beta.AsyncBetaResourceWithStreamingResponser=rrorlrr-se  PP"TT" O OIIror)\ __future__rr]typingrrrrtyping_extensionsrr r httpxr _qsrtypesrr_typesrrrrrrrrrrrr_utilsrrrr r!_compatr"_versionr# _responser$r%r&r' _streamingr(r)r*r+ _base_clientr,r-r.r/types.search_resultr0types.extract_responser1$types.advanced_search_settings_paramr2%types.advanced_extract_settings_paramr3 resourcesr4r5r6r7ryr8r9rrr:r;resources.beta.betar<r=rur>r?__all__r@rArrrrrBrCrrorlrs# 8855 >    %! E6 .3MO>>HIDO EE}EEP EENEEP C>C>LCCCCLCDCDLCICIL  ro