_j^dSSKJr SSKrSSKJrJrJrJrJrJ r J r SSK J r SSK r SSKJrJrJrJrJrJrJr SSKJrJrJrJrJr SSKJr SS KJrJ r SS K!J"r"J#r#J$r$J%r% SS K&J'r'J(r( SS K)J*r*J+r+ SS K,J-r- SSK.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9 SSK:J;r; SSKJ?r? SS/r@"SS\5rA"SS\ 5rB"SS5rC"SS5rD"SS 5rE"S!S"5rFg)#) annotationsN)AnyDictListUnionIterableOptionalcast)chain)BodyOmitQueryHeadersNotGivenomit not_given)is_given path_templatemaybe_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) WebhookParam) TaskRunResult) TaskSpecParam)McpServerParam)ParallelBetaParam) SourcePolicy)TaskAdvancedSettingsParam)TaskRunEventsResponseTaskRunResourceAsyncTaskRunResourcec\rSrSrSr\SSj5r\SSj5r\R"S5\ \ \ \ \ \ \ \ \ SSS\ S. SSjj5r \R"S5SSS\ S .SS jj5r \R"S5\ \ SSS\ S .SS jj5rS rg)r.%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 c[U5$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 )TaskRunResourceWithRawResponseselfs U/home/rurouni/.local/lib/python3.13/site-packages/parallel/resources/beta/task_run.pywith_raw_response!TaskRunResource.with_raw_response3s.d33c[U5$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 )$TaskRunResourceWithStreamingResponser6s r8with_streaming_response'TaskRunResource.with_streaming_response=s4D99r;Use GA Task Run insteadN advanced_settings enable_events mcp_serversmetadataprevious_interaction_id source_policy task_specwebhookbetas extra_headers extra_query extra_bodytimeoutcD0[S[U 5(a#SR[SU 5S/55O[05EU =(d 0En SS0U =(d 0En UR S[ UUUUUUUUU U S. [R5[XXS9[S9$) ) 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. advanced_settings: Advanced search configuration for a task run. 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://docs.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). mcp_servers: Optional list of MCP servers to use for the run. 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,c38# UHn[U5v M g7fNstr.0es r8 )TaskRunResource.create..4KUSVVUsearch-extract-2025-10-10/v1/tasks/runs input processorrCrDrErFrGrHrIrJrLrMrNrObodyoptionscast_to) rrjoinr r_postrr"TaskRunCreateParamsr$r%r7rbrcrCrDrErFrGrHrIrJrKrLrMrNrOs r8createTaskRunResource.createFsR  #&)XXe4KU4KNiMj.k%l"  "  )*E_-J][]_ zz  "!*):%2#. (/F%2!*& '::)+Q[)  r;rdc U(d[SU<35eSS0U=(d 0EnSS0U=(d 0EnUR[SUS9[X#XES9[ [ [ 5S [[ S 9$)  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-streamrRr_"/v1beta/tasks/runs/{run_id}/eventsrun_idrdTrgrhstream stream_cls) ValueError_getrr$r rr-r r7rvrLrMrNrOs r8eventsTaskRunResource.eventss<TU[T^_` `!#6P=;NBP (*E_-J][]_ yy >v N(+Q[3434  r; api_timeoutrKrLrMrNrOc rU(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[UUUU[SU0[R5S 9[S 9$)  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 rqrRrSc38# UHn[U5v M g7frUrVrXs r8r[)TaskRunResource.result..r]r^r_/v1/tasks/runs/{run_id}/resultrurrLrMrNrOqueryrgrh) rzrrrir rr{rr$rr#TaskRunResultParamsr'r7rvrrKrLrMrNrOs r8resultTaskRunResource.results8TU[T^_` `  #&)XXe4KU4KNiMj.k%l"  "  )*E_-J][]_ yy :6 J(+'%%}k&BDZDnDno "  r;)returnr5)rr> rbzUnion[str, Dict[str, object]]rcrWrCz*Optional[TaskAdvancedSettingsParam] | OmitrDzOptional[bool] | OmitrEz)Optional[Iterable[McpServerParam]] | OmitrFz3Optional[Dict[str, Union[str, float, bool]]] | OmitrGzOptional[str] | OmitrHzOptional[SourcePolicy] | OmitrIzOptional[TaskSpecParam] | OmitrJzOptional[WebhookParam] | OmitrKList[ParallelBetaParam] | OmitrLHeaders | NonerM Query | NonerN Body | NonerO'float | httpx.Timeout | None | NotGivenrr%) rvrWrLrrMrrNrrOrrzStream[TaskRunEventsResponse]rvrWrz int | OmitrKrrLrrMrrNrrOrrr'__name__ __module__ __qualname____firstlineno____doc__rr9r?typing_extensions deprecatedrrrmr}r__static_attributes__rr;r8r.r.%s 44::!!";< IM/3AEHL8<7;481504)-$("&;D'h -h  h F h - h ?h Fh "6h 5h 2h /h .h &!h ""#h $ %h &9'h ( )h =h T!!";<)-$("&;D) ) & ) ")  ) 9)  ') =) V!!";< #'04)-$("&;D2 2  2 . 2 &2 "2  2 92  2 =2 r;c\rSrSrSr\SSj5r\SSj5r\R"S5\ \ \ \ \ \ \ \ \ SSS\ S. SSjj5r \R"S5SSS\ S .SS jj5r \R"S5\ \ SSS\ S .SS jj5rS rg)r/ir2c[U5$r4)#AsyncTaskRunResourceWithRawResponser6s r8r9&AsyncTaskRunResource.with_raw_response!s3488r;c[U5$r=))AsyncTaskRunResourceWithStreamingResponser6s r8r?,AsyncTaskRunResource.with_streaming_response+s9>>r;rANrBct# 0[S[U 5(a#SR[SU 5S/55O[05EU =(d 0En SS0U =(d 0En UR S[ UUUUUUUUU U S. [R5IShvN [XXS9[S 9IShvN $NN7f) rQrRrSc38# UHn[U5v M g7frUrVrXs r8r[.AsyncTaskRunResource.create..r]r^r_r`raNrdre) rrrir rrjrr"rkr$r%rls r8rmAsyncTaskRunResource.create4sR  #&)XXe4KU4KNiMj.k%l"  "  )*E_-J][]_ ZZ ,"!*):%2#. (/F%2!*& '::)+Q[)     s$BB8B4 B8/B60B86B8rdc # U(d[SU<35eSS0U=(d 0EnSS0U=(d 0EnUR[SUS9[X#XES9[ [ [ 5S [[ S 9IS hvN $N7f) rprqrrrsrRr_rtrurdTrwN)rzr{rr$r rr-r!r|s r8r}AsyncTaskRunResource.eventss<TU[T^_` `!#6P=;NBP (*E_-J][]_ YY >v N(+Q[34"#89    sA8B:A?;Brc # U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[UUUU[SU0[R5IS hvN S 9[S 9IS hvN $NN7f) rrqrRrSc38# UHn[U5v M g7frUrVrXs r8r[.AsyncTaskRunResource.result..r]r^r_rrurNrr) rzrrrir rr{rr$rr#rr'rs r8rAsyncTaskRunResource.results8TU[T^_` `  #&)XXe4KU4KNiMj.k%l"  "  )*E_-J][]_ YY :6 J(+'%1"K02H2\2\ "     s$B3C5C 6CC C Cr)rr)rrr) rvrWrLrrMrrNrrOrrz"AsyncStream[TaskRunEventsResponse]rrrr;r8r/r/s 99??!!";< IM/3AEHL8<7;481504)-$("&;D'h -h  h F h - h ?h Fh "6h 5h 2h /h .h &!h ""#h $ %h &9'h ( )h =h T!!";<)-$("&;D) ) & ) ")  ) 9)  ,) =) V!!";< #'04)-$("&;D4 4  4 . 4 &4 "4  4 94  4 =4 r;c\rSrSrSSjrSrg)r5icXl[UR5Ul[UR5Ul[UR5UlgrU) _task_runrrmr}rr7task_runs r8__init__'TaskRunResourceWithRawResponse.__init__sO! $  $  $  r;rrmr}rNrr.rNonerrrrrrrr;r8r5r5 r;r5c\rSrSrSSjrSrg)ricXl[UR5Ul[UR5Ul[UR5UlgrU)rrrmr}rrs r8r,AsyncTaskRunResourceWithRawResponse.__init__sO! *  *  *  r;rNrr/rrrrr;r8rrrr;rc\rSrSrSSjrSrg)r>i-cXl[UR5Ul[UR5Ul[UR5UlgrU)rrrmr}rrs r8r-TaskRunResourceWithStreamingResponse.__init__.sO! )  )  )  r;rNrrrr;r8r>r>-rr;r>c\rSrSrSSjrSrg)riBcXl[UR5Ul[UR5Ul[UR5UlgrU)rrrmr}rrs r8r2AsyncTaskRunResourceWithStreamingResponse.__init__CsO! /  /  /  r;rNrrrr;r8rrBrr;r)G __future__rrtypingrrrrrr r itertoolsr httpx_typesr rrrrrr_utilsrrrrr_compatr _resourcerr _responserrrr _streamingr r! types.betar"r# _base_clientr$types.task_runr%types.webhook_paramr&types.task_run_resultr'types.task_spec_paramr(types.mcp_server_paramr)types.beta.parallel_beta_paramr*!types.shared_params.source_policyr+"types.task_advanced_settings_paramr,#types.beta.task_run_events_responser-__all__r.r/r5rr>rrr;r8rs#CCC KKKff&: .H0%/224?=KH 4 5k ok \m +m `  *  *  *  r;