_jk(SSKJr SSKrSSKJrJrJrJrJrJ r J r J r J r SSK r SSKJr SSKJrJr SSKJrJrJrJrJrJrJr SSKJrJrJrJrJ r SS K!J"r" SS K#J$r$J%r% SS K&J'r'J(r(J)r)J*r* SS K+J,r,J-r- SS K.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9J:r:J;r; SSKJ?r? SSK@JArA SSKBJCrDJErFJGrG SSKHJIrI SSKJJKrK SSKLJMrM SSKNJOrO SS/rP"SS\$5rQ"SS\%5rR"SS 5rS"S!S"5rT"S#S$5rU"S%S&5rVg)') annotationsN) AnyDictListTypeUnionIterableOptionalcastoverload)prepare_timeout_float)task_run_create_paramstask_run_result_params)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)make_request_options)TaskRun)RunInput) WebhookParam) TaskRunResult)OutputT OutputSchema TaskSpecParam)McpServerParam)build_task_spec_param)ParsedTaskRunResult)wait_for_resultwait_for_result_asynctask_run_result_parser)ParallelBetaParam)TaskRunEventsResponse) SourcePolicy)TaskAdvancedSettingsParamTaskRunResourceAsyncTaskRunResourcecj\rSrSrSr\SSj5r\SSj5r\\\\\\\\\SSS\ S. SSjjr SSS\ S.SS jjr SSS\ S.SS jjr \\SSS\ S .SS jjr SSS\ S.SS jjr\SSSS.SSjjr\\\SSS\ S.SSjj5r\\SSS\ S.SSjj5r\\SSS\ S.S SjjrSrg)!r8.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 P/home/rurouni/.local/lib/python3.13/site-packages/parallel/resources/task_run.pywith_raw_response!TaskRunResource.with_raw_response<s.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 )$TaskRunResourceWithStreamingResponser@s rBwith_streaming_response'TaskRunResource.with_streaming_responseFs4D99rEN advanced_settings enable_events mcp_serversmetadataprevious_interaction_id source_policy task_specwebhookbetas extra_headers extra_query extra_bodytimeoutc0[S[U 5(aSRSU 55O[05EU =(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 rB )TaskRunResource.create..8OAQ/v1/tasks/runs input processorrLrMrNrOrPrQrRrSrUrVrWrXbodyoptionscast_to) rrjoinr_postrrTaskRunCreateParamsr&r'rArjrkrLrMrNrOrPrQrRrSrTrUrVrWrXs rBcreateTaskRunResource.createOsP S[\aSbSb8O8O0Ohqrs " zz  "!*):%2#. (/F%2!*& '::)+Q[)  rErlc xU(d[SU<35eUR[SUS9[X#XES9[S9$)U Retrieves run status by run_id. The run result is available from the `/result` endpoint. 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 /v1/tasks/runs/{run_id}run_idrlrorp ValueError_getrr&r'rAr|rUrVrWrXs rBretrieveTaskRunResource.retrievesP2TU[T^_` `yy 3F C(+Q[   rEc U(d[SU<35eSS0U=(d 0EnUR[SUS9[X#XES9[ [ [ 5S[[ S9$)  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 ryAccepttext/event-stream/v1/tasks/runs/{run_id}/eventsr{rlTrorpstream stream_cls)rrrr&r rr5r$rs rBeventsTaskRunResource.eventssy:TU[T^_` `!#6P=;NBP yy :6 J(+Q[3434  rE api_timeoutrTrUrVrWrXc >U(d[SU<35e0[S[U5(aSRSU55O[05EU=(d 0EnUR [ SUS9[UUUU[SU0[R5S9[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 ryr[r\c38# UHn[U5v M g7fr^r_ras rBrd)TaskRunResource.result..rfrg/v1/tasks/runs/{run_id}/resultr{rrUrVrWrXqueryr}) rrrrqrrrr&rrTaskRunResultParamsr*rAr|rrTrUrVrWrXs rBresultTaskRunResource.results6TU[T^_` ` S[\aSbSb8O8O0Ohqrs " yy :6 J(+'%%}k&BDZDnDno "  rEc xU(d[SU<35eUR[SUS9[X#XES9[S9$)# Retrieves the input of a run by run_id. 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 ry/v1/tasks/runs/{run_id}/inputr{rlr}rrrr&r(rs rBretrieve_inputTaskRunResource.retrieve_input,sP.TU[T^_` `yy 9& I(+Q[   rEoutputrUrVrWc8^^^^^SUUUUU4Sjjn[XUS9$)9Wait for a task run to complete within the given timeout.cr>U[R"5- nTRUTTTUS9n[UT5$Nrltime monotonicrr3 r|deadlinerXtask_run_resultrWrUrVrrAs rB_fetcher2TaskRunResource._wait_for_result.._fetcher[sE!11G"kk+'% *O*/6B BrEr|rcallabler|r`rfloatreturn,TaskRunResult | ParsedTaskRunResult[OutputT])_wait_for_resultrAr|rrrUrVrWrs` ```` rBr TaskRunResource._wait_for_resultMs C C v8TTrErOrrUrVrWrXcgr^ rArjrkrOrrUrVrWrXs rBexecuteTaskRunResource.executehsrErOrUrVrWrXcgr^rrs rBrrws(+rEc SS0U=(d 0En[U5n[R"5U-n URUUU[ XA5UUUUS9n UR U R U UUUUS9$) Convenience method to create and execute a task run in a single call. Awaits run completion. If the run is successful, a `ParsedTaskRunResult` is returned when a pydantic was specified in `output`. Otherwise, a `TaskRunResult` is returned. Possible errors: - `TimeoutError`: If the run does not finish within the specified timeout. - `APIStatusError`: If the API returns a non-200-range status code. - `APIConnectionError`: If the connection to the API fails. Args: input: Input to the task, either text or a JSON object. processor: Processor to use for the task. metadata: User-provided metadata stored with the run. Keys and values must be strings with a maximum length of 16 and 512 characters respectively. output: Optional output schema or pydantic type. If pydantic is provided, the response will have a parsed field. 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. If the result is not available within the timeout, a `TimeoutError` is raised. X-Stainless-Poll-HelpertruerjrkrOrRrUrVrWrXr|rrrUrVrWr rrrur/rr| rArjrkrOrrUrVrWrXrtask_runs rBrrs\3FT}?RPRT '0>>#g-;;+F:'#!  $$??'#! %  rEr)rr?)rrH rjUnion[str, Dict[str, object]]rkr`rLz*Optional[TaskAdvancedSettingsParam] | OmitrMzOptional[bool] | OmitrNz)Optional[Iterable[McpServerParam]] | OmitrO3Optional[Dict[str, Union[str, float, bool]]] | OmitrPzOptional[str] | OmitrQzOptional[SourcePolicy] | OmitrRzOptional[TaskSpecParam] | OmitrSzOptional[WebhookParam] | OmitrTList[ParallelBetaParam] | OmitrUHeaders | NonerV Query | NonerW Body | NonerX'float | httpx.Timeout | None | NotGivenrr' r|r`rUrrVrrWrrXrrr') r|r`rUrrVrrWrrXrrzStream[TaskRunEventsResponse]r|r`rz int | OmitrTrrUrrVrrWrrXrrr* r|r`rUrrVrrWrrXrrr(r|r`rrr-Optional[OutputSchema] | Type[OutputT] | OmitrUrrVrrWrrrrjrrkr`rOrrzOptional[OutputSchema] | OmitrUrrVrrWrrXrrr*rjrrkr`rOrrz Type[OutputT]rUrrVrrWrrXrrzParsedTaskRunResult[OutputT]rjrrkr`rOrrrrUrrVrrWrrXrrr__name__ __module__ __qualname____firstlineno____doc__rrCrIrrrurrrrrr r__static_attributes__rrErBr8r8.sa 44::IM/3AEHL8<7;481504)-$("&;D'a -a  a F a - a ?a Fa "6a 5a 2a /a .a &!a ""#a $ %a &9'a ( )a R)-$("&;D! ! & ! "!  ! 9!  ! R)-$("&;D( ( & ( "(  ( 9(  '( \#'04)-$("&;D+ +  + . + &+ "+  + 9+  + f)-$("&;D  &  "   9   LAE)-$("&UU U > U&U"U U 6U6 IM04)-$("&;D -   F  . & "   9     IM)-$("&;D +- + + F +  +& +" +  +9 + & + +&IM@D)-$("&;DE -E  E F E > E &E "E  E 9E  6E E rEcj\rSrSrSr\SSj5r\SSj5r\\\\\\\\\SSS\ S. SSjjr SSS\ S.SS jjr SSS\ S.SS jjr \\SSS\ S .SS jjr SSS\ S.SS jjr\SSSS.SSjjr\\\SSS\ S.SSjj5r\\SSS\ S.SSjj5r\\SSS\ S.S SjjrSrg)!r9ir<c[U5$r>)#AsyncTaskRunResourceWithRawResponser@s rBrC&AsyncTaskRunResource.with_raw_responses3488rEc[U5$rG))AsyncTaskRunResourceWithStreamingResponser@s rBrI,AsyncTaskRunResource.with_streaming_responses9>>rENrKc@# 0[S[U 5(aSRSU 55O[05EU =(d 0En UR S[ UUUUUUUUU U S. [ R5IShvN [XXS9[S9IShvN $NN7f) rZr[r\c38# UHn[U5v M g7fr^r_ras rBrd.AsyncTaskRunResource.create..7rfrgrhriNrlrm) rrrqrrrrrrsr&r'rts rBruAsyncTaskRunResource.createsP S[\aSbSb8O8O0Ohqrs " ZZ ,"!*):%2#. (/F%2!*& '::)+Q[)     s$A;B=B >BBBBrlc # U(d[SU<35eUR[SUS9[X#XES9[S9IShvN $N7f)rxryrzr{rlr}Nr~rs rBrAsyncTaskRunResource.retrieveQs]2TU[T^_` `YY 3F C(+Q[     ?AAAc # U(d[SU<35eSS0U=(d 0EnUR[SUS9[X#XES9[ [ [ 5S[[ S9IS hvN $N7f) rryrrrr{rlTrN)rrrr&r rr5r%rs rBrAsyncTaskRunResource.eventsts:TU[T^_` `!#6P=;NBP YY :6 J(+Q[34"#89    sA)A2+A0,A2rc n# U(d[SU<35e0[S[U5(aSRSU55O[05EU=(d 0EnUR [ SUS9[UUUU[SU0[R5IShvN S 9[S 9IShvN $NN7f) rryr[r\c38# UHn[U5v M g7fr^r_ras rBrd.AsyncTaskRunResource.result..rfrgrr{rNrr}) rrrrqrrrr&rrrr*rs rBrAsyncTaskRunResource.results6TU[T^_` ` S[\aSbSb8O8O0Ohqrs " YY :6 J(+'%1"K02H2\2\ "     s$BB5B1B5,B3-B53B5c # U(d[SU<35eUR[SUS9[X#XES9[S9IShvN $N7f)rryrr{rlr}Nrrs rBr#AsyncTaskRunResource.retrieve_inputs].TU[T^_` `YY 9& I(+Q[     rrcT^^^^^# SUUUUU4Sjjn[XUS9IShvN $N7f)rc># U[R"5- nTRUTTTUS9IShvN n[UT5$N7frrrs rBr7AsyncTaskRunResource._wait_for_result.._fetchersR!11G$(KK+'% %0%O*/6B Bs/AAArNr)_wait_for_result_asyncrs` ```` rBr%AsyncTaskRunResource._wait_for_results( C C,6W_````s (&(rc # g7fr^rrs rBrAsyncTaskRunResource.execute s rc # g7fr^rrs rBrrs (+rc # SS0U=(d 0En[U5n[R"5U-n URUUU[ XA5UUUUS9IShvN n UR U R U UUUUS9IShvN $N*N7f)rrrrNrrrs rBrr#s\3FT}?RPRT '0>>#g-+F:'#!%   **??'#! +      s$ABB%B=B>BBr)rr)rrrr) r|r`rUrrVrrWrrXrrz"AsyncStream[TaskRunEventsResponse]rrrrrrrrrErBr9r9s] 99??IM/3AEHL8<7;481504)-$("&;D'a -a  a F a - a ?a Fa "6a 5a 2a /a .a &!a ""#a $ %a &9'a ( )a R)-$("&;D! ! & ! "!  ! 9!  ! R)-$("&;D( ( & ( "(  ( 9(  ,( \#'04)-$("&;D- -  - . - &- "-  - 9-  - j)-$("&;D  &  "   9   LAE)-$("&aa a > a&a"a a 6a6 IM04(,$("&;D -   F  . & "   9     IM(,$("&;D +- + + F +  +& +" +  +9 + & + +"IM@D)-$("&;DE -E  E F E > E &E "E  E 9E  6E E rEc\rSrSrSSjrSrg)r?ijcXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ulgr^) _task_runr rurrrrrArs rB__init__'TaskRunResourceWithRawResponse.__init__kss!- OO  0     . OO  . OO  6  # # rErrurrrrNrr8rNonerrrrrrrrErBr?r?j rEr?c\rSrSrSSjrSrg)ricXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ulgr^)rr"rurrrrrs rBr,AsyncTaskRunResourceWithRawResponse.__init__ss!3 OO  6     4 OO  4 OO  <  # # rErNrr9rrr rrErBrrr rErc\rSrSrSSjrSrg)rHicXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ulgr^)rr!rurrrrrs rBr-TaskRunResourceWithStreamingResponse.__init__ss!2 OO  5     3 OO  3 OO  ;  # # rErNrr rrErBrHrHr rErHc\rSrSrSSjrSrg)ricXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ulgr^)rr#rurrrrrs rBr2AsyncTaskRunResourceWithStreamingResponse.__init__st!8 OO  ;     9 OO  9 OO  A  # # rErNrr rrErBrrr rEr)W __future__rrtypingrrrrrr r r r httpxparallel.lib._timer typesrr_typesrrrrrrr_utilsrrrrr_compatr _resourcerr _responser r!r"r# _streamingr$r% _base_clientr&types.task_runr'types.run_inputr(types.webhook_paramr)types.task_run_resultr*types.task_spec_paramr+r,r-types.mcp_server_paramr.lib._parsing._task_specr/types.parsed_task_run_resultr0lib._parsing._task_run_resultr1rr2rr3types.beta.parallel_beta_paramr4types.task_run_events_responser5!types.shared_params.source_policyr6"types.task_advanced_settings_paramr7__all__r8r9r?rrHrrrErBr/s# SSS 4BJJJee%9 -/$&.1HH3;> ?B<J 4 5] o] ~ [ +[ z   *  *  *  rE