0j[ddlmZddlmZmZmZmZmZmZm Z ddl m Z ddl Z ddl mZmZmZmZmZmZmZddlmZmZmZmZddlmZdd lmZmZdd lm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&dd l'm(Z(m)Z)dd l*m+Z+ddl,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddgZ<GddeZ=GddeZ>GddZ?GddZ@GddZAGd d!ZBdS)") annotations)AnyDictListUnionIterableOptionalcast)chainN)BodyOmitQueryHeadersNotGivenomit not_given)is_givenmaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream)task_run_create_paramstask_run_result_params)make_request_options)TaskRun) TaskSpecParam) WebhookParam)McpServerParam)ParallelBetaParam)BetaTaskRunResult) SourcePolicy)TaskRunEventsResponseTaskRunResourceAsyncTaskRunResourcec eZdZdZed0dZed1dZeeeeeeeeddded d2d&Z ddded'd3d*Z eeddded+d4d/Z dS)5r,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 returnTaskRunResourceWithRawResponsec 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 )r1selfs h/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/parallel/resources/beta/task_run.pywith_raw_responsez!TaskRunResource.with_raw_response*s.d333$TaskRunResourceWithStreamingResponsec 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 )r9r4s r6with_streaming_responsez'TaskRunResource.with_streaming_response4s4D999r8N enable_events mcp_serversmetadataprevious_interaction_id source_policy task_specwebhookbetas extra_headers extra_query extra_bodytimeoutinputUnion[str, Dict[str, object]] processorstrr>Optional[bool] | Omitr?)Optional[Iterable[McpServerParam]] | Omitr@3Optional[Dict[str, Union[str, float, bool]]] | OmitrAOptional[str] | OmitrBOptional[SourcePolicy] | OmitrCOptional[TaskSpecParam] | OmitrDOptional[WebhookParam] | OmitrEList[ParallelBetaParam] | OmitrFHeaders | NonerG Query | NonerH Body | NonerI'float | httpx.Timeout | None | NotGivenr$cfitdt| r.dtd| Ddgnti| pi} ddi| pi} |dt ||||||||| d tjt| | | |tS) [ Initiates a task run. Returns immediately with a run object in status 'queued'. Beta features can be enabled by setting the 'parallel-beta' header. Args: input: Input to the task, either text or a JSON object. processor: Processor to use for the task. enable_events: Controls tracking of task run execution progress. When set to true, progress events are recorded and can be accessed via the [Task Run events](https://platform.parallel.ai/api-reference) endpoint. When false, no progress events are tracked. Note that progress tracking cannot be enabled after a run has been created. The flag is set to true by default for premium processors (pro and above). To enable this feature in your requests, specify `events-sse-2025-07-24` as one of the values in `parallel-beta` header (for API calls) or `betas` param (for the SDKs). mcp_servers: Optional list of MCP servers to use for the run. To enable this feature in your requests, specify `mcp-server-2025-07-17` as one of the values in `parallel-beta` header (for API calls) or `betas` param (for the SDKs). metadata: User-provided metadata stored with the run. Keys and values must be strings with a maximum length of 16 and 512 characters respectively. previous_interaction_id: Interaction ID to use as context for this request. source_policy: Source policy for web search results. This policy governs which sources are allowed/disallowed in results. task_spec: Specification for a task. Auto output schemas can be specified by setting `output_schema={"type":"auto"}`. Not specifying a TaskSpec is the same as setting an auto output schema. For convenience bare strings are also accepted as input or output schemas. 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,c34K|]}t|VdSNrM.0es r6 z)TaskRunResource.create..(4K4KSVV4K4K4K4K4K4Kr8search-extract-2025-10-10/v1/tasks/runs?beta=true rJrLr>r?r@rArBrCrDrFrGrHrIbodyoptionscast_to) rrjoinr r_postrr!TaskRunCreateParamsr#r$r5rJrLr>r?r@rArBrCrDrErFrGrHrIs r6createzTaskRunResource.create=sR  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ zz & "!*%2#. (/F%2!*&  ':  )+Q[el'   r8rirun_idStream[TaskRunEventsResponse]c |std|ddi|pi}ddi|pi}|d|dt||||ttt d t t  S) @ Streams events for a task run. Returns a stream of events showing progress updates and state changes for the task run. For task runs that did not have enable_events set to true during creation, the frequency of events will be reduced. Args: 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 5Expected a non-empty value for `run_id` but received Accepttext/event-streamr\rf/v1beta/tasks/runs//eventsriTrlrmstream stream_cls) ValueError_getr#r rr+rr5rsrFrGrHrIs r6eventszTaskRunResource.eventss: a_U[__`` `!#6P=;NBP (*E_-J][]_ yy 1& 1 1 1(+Q[el34434   r8 api_timeoutrErFrGrHrIr int | Omitr)c |std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||td|itj  t S)  Retrieves a run result by run_id, blocking until the run is completed. 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 rwr\r]c34K|]}t|VdSr_r`ras r6rdz)TaskRunResource.result..rer8rf/v1/tasks/runs//result?beta=truerrFrGrHrIqueryrlrm) rrrrnr rrr#rr"TaskRunResultParamsr)r5rsrrErFrGrHrIs r6resultzTaskRunResource.results6 a_U[__`` `  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ yy 7f 7 7 7(+'%%}k&BDZDnoo &   r8)r0r1)r0r9rJrKrLrMr>rNr?rOr@rPrArQrBrRrCrSrDrTrErUrFrVrGrWrHrXrIrYr0r$) rsrMrFrVrGrWrHrXrIrYr0rtrsrMrrrErUrFrVrGrWrHrXrIrYr0r) __name__ __module__ __qualname____doc__rr7r<rrrrrrr8r6r,r,#s  444_4:::_:04AEHL8<7;481504)-$("&;D%h h h h h h `)-$("&;D) ) ) ) ) ) ^#'04)-$("&;D2 2 2 2 2 2 2 2 r8c eZdZdZed0dZed1dZeeeeeeeeddded d2d&Z ddded'd3d*Z eeddded+d4d/Z dS)5r-r/r0#AsyncTaskRunResourceWithRawResponsec t|Sr3)rr4s r6r7z&AsyncTaskRunResource.with_raw_responses34888r8)AsyncTaskRunResourceWithStreamingResponsec t|Sr;)rr4s r6r<z,AsyncTaskRunResource.with_streaming_responses9>>>r8Nr=rJrKrLrMr>rNr?rOr@rPrArQrBrRrCrSrDrTrErUrFrVrGrWrHrXrIrYr$cKitdt| r.dtd| Ddgnti| pi} ddi| pi} |dt ||||||||| d tjd{Vt| | | |t d{VS) r[r\r]c34K|]}t|VdSr_r`ras r6rdz.AsyncTaskRunResource.create..mrer8rfrgrhNrirj) rrrnr rrorr!rpr#r$rqs r6rrzAsyncTaskRunResource.create!sFR  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ ZZ &,"!*%2#. (/F%2!*&  ':        )+Q[el'          r8rirs"AsyncStream[TaskRunEventsResponse]c K|std|ddi|pi}ddi|pi}|d|dt||||ttt d t t  d {VS) rvrwrxryr\rfrzr{riTr|N)rrr#r rr+r rs r6rzAsyncTaskRunResource.eventss: a_U[__`` `!#6P=;NBP (*E_-J][]_ YY 1& 1 1 1(+Q[el344"#89         r8rrrr)c K|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||td|itj d {V t d {VS) rrwr\r]c34K|]}t|VdSr_r`ras r6rdz.AsyncTaskRunResource.result..rer8rfrrrNrr) rrrrnr rrr#rr"rr)rs r6rzAsyncTaskRunResource.resultsS6 a_U[__`` `  #&#SXXe4K4KU4K4K4KNiMj.k.k%l%l%l"  "  )*E_-J][]_ YY 7f 7 7 7(+'%1"K02H2\ &         r8)r0r)r0rr) rsrMrFrVrGrWrHrXrIrYr0rrrrr8r6r-r-s  999_9???_?04AEHL8<7;481504)-$("&;D%h h h h h h `)-$("&;D) ) ) ) ) ) ^#'04)-$("&;D4 4 4 4 4 4 4 4 r8ceZdZddZdS)r1task_runr,r0Nonec||_t|j|_t|j|_t|j|_dSr_) _task_runrrrrrr5rs r6__init__z'TaskRunResourceWithRawResponse.__init__sS!- O   . O   . O   r8Nrr,r0rrrrrrr8r6r1r1(       r8r1ceZdZddZdS)rrr-r0rc||_t|j|_t|j|_t|j|_dSr_)rrrrrrrs r6rz,AsyncTaskRunResourceWithRawResponse.__init__sS!3 O   4 O   4 O   r8Nrr-r0rrrr8r6rrrr8rceZdZddZdS)r9rr,r0rc||_t|j|_t|j|_t|j|_dSr_)rrrrrrrs r6rz-TaskRunResourceWithStreamingResponse.__init__ sS!2 O   3 O   3 O   r8Nrrrr8r6r9r9 rr8r9ceZdZddZdS)rrr-r0rc||_t|j|_t|j|_t|j|_dSr_)rrrrrrrs r6rz2AsyncTaskRunResourceWithStreamingResponse.__init__sS!8 O   9 O   9 O   r8Nrrrr8r6rrrr8r)C __future__rtypingrrrrrr r itertoolsr httpx_typesr rrrrrr_utilsrrrr_compatr _resourcerr _responserrrr _streamingrr types.betar!r" _base_clientr#types.task_runr$types.task_spec_paramr%types.beta.webhook_paramr&types.beta.mcp_server_paramr'types.beta.parallel_beta_paramr(types.beta.beta_task_run_resultr)!types.shared_params.source_policyr*#types.beta.task_run_events_responser+__all__r,r-r1rr9rrr8r6rs#"""""CCCCCCCCCCCCCCCCCC KKKKKKKKKKKKKKKKKKWWWWWWWWWWWW&&&&&&:::::::: .-------HHHHHHHH000000%%%%%%222222444444999999??????@@@@@@======HHHHHH 4 5a a a a a oa a a Hc c c c c +c c c L                                      r8