_jSSKJr SSKJrJrJrJrJrJrJ r SSK J r SSK r SSK JrJrJrJr SSKJrJrJrJrJrJrJr SSKJrJrJrJrJr 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. SSK/J0r0 SSK1J2r2 SSK3J4r4 SSK5J6r6 SSK7J8r8 SSK9J:r: SSK;Jr> SS/r?"SS\#5r@"SS\$5rA"SS5rB"SS5rC"SS5rD"S S!5rEg)") annotations)AnyDictListUnionIterableOptionalcast)LiteralN)task_group_create_paramstask_group_events_paramstask_group_add_runs_paramstask_group_get_runs_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) TaskGroup) RunInputParam) TaskSpecParam)TaskGroupRunResponse)ParallelBetaParam)TaskGroupEventsResponse)TaskGroupGetRunsResponseTaskGroupResourceAsyncTaskGroupResourcec \rSrSrSr\SSj5r\SSj5r\SSS\ S.SSjjr SSS\ S.SS jjr \\\SSS\ S .SS jjr \\SSS\ S .SS jjr \\\\SSS\ S.SSjjrSSS\ S.SSjjrSrg)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 ) TaskGroupResourceWithRawResponseselfs R/home/rurouni/.local/lib/python3.13/site-packages/parallel/resources/task_group.pywith_raw_response#TaskGroupResource.with_raw_response6s055c[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 )&TaskGroupResourceWithStreamingResponser7s r9with_streaming_response)TaskGroupResource.with_streaming_response@s6d;;r<Nmetadata extra_headers extra_query extra_bodytimeoutc rURS[SU0[R5[ X#XES9[ S9$)s Initiates a TaskGroup to group and track multiple runs. Args: metadata: User-provided metadata stored with the task group. 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/tasks/groupsrCrDrErFrGbodyoptionscast_to)_postrr TaskGroupCreateParamsr&r(r8rCrDrErFrGs r9createTaskGroupResource.createIsF2zz  *h!79Q9g9gh(+Q[   r<rKc xU(d[SU<35eUR[SUS9[X#XES9[S9$)3 Retrieves aggregated status across runs in a TaskGroup. 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 -TaskGroupResource.add_runs..8OAQ%/v1/tasks/groups/{task_group_id}/runsrYinputsrdrcrDrErFrGqueryrL) r]rrjoinrrPrrrTaskGroupAddRunsParamsr&r+ r8rZrwrcrdrerDrErFrGs r9add_runsTaskGroupResource.add_runssN[\i[lmn n S[\aSbSb8O8O0Ohqrs " zz AQ^ _ $):+AA )+'%%%~68R8i8i )%  r< last_event_id api_timeoutrDrErFrGcU(d[SU<35eSS0U=(d 0EnUR[SUS9[UUUU[ UUS.[ R 5S9[[[5S[[S 9$)  Streams events from a TaskGroup: status updates and run completions. The connection will remain open for up to an hour as long as at least one run in the group is still active. 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 rWAccepttext/event-stream'/v1/tasks/groups/{task_group_id}/eventsrYrrrxTrNrOstream stream_cls) r]r^rr&rrTaskGroupEventsParamsr rr-r$r8rZrrrDrErFrGs r9eventsTaskGroupResource.eventss8[\i[lmn n!#6P=;NBP yy CS` a(+'%%)6'2-BB  ,56'  r< include_inputinclude_outputrstatusrDrErFrGc U(d[SU<35eSS0U=(d 0EnUR[SUS9[UUUU [ UUUUS.[ R 5S9[[[5S[[S 9$)  Retrieves task runs in a TaskGroup and optionally their inputs and outputs. All runs within a TaskGroup are returned as a stream. To get the inputs and/or outputs back in the stream, set the corresponding `include_input` and `include_output` parameters to `true`. The stream is resumable using the `event_id` as the cursor. To resume a stream, specify the `last_event_id` parameter with the `event_id` of the last event in the stream. The stream will resume from the next event after the `last_event_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 rWrrrurYrrrrrxTr) r]r^rr&rrTaskGroupGetRunsParamsr rr.r$ r8rZrrrrrDrErFrGs r9get_runsTaskGroupResource.get_runssN[\i[lmn n!#6P=;NBP yy AQ^ _(+'%%)6*8)6"(  /EE -67+  r<c U(d[SU<35eU(d[SU<35eUR[SX!S9[X4XVS9[S9$) Retrieves run status by run_id. This endpoint is equivalent to fetching run status directly using the `retrieve()` method or the `tasks/runs` GET endpoint. 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 rW5Expected a non-empty value for `run_id` but received ./v1/tasks/groups/{task_group_id}/runs/{run_id}rZrun_idrKr[r]r^rr&r'r8rrZrDrErFrGs r9 retrieve_runTaskGroupResource.retrieve_runEsi:[\i[lmn nTU[T^_` `yy JZg w(+Q[   r<)returnr6)rr? rCz3Optional[Dict[str, Union[str, float, bool]]] | OmitrDHeaders | NonerE Query | NonerF Body | NonerG'float | httpx.Timeout | None | NotGivenrr( rZrmrDrrErrFrrGrrr(rZrmrwzIterable[RunInputParam]rc bool | OmitrdzOptional[TaskSpecParam] | OmitrezList[ParallelBetaParam] | OmitrDrrErrFrrGrrr+)rZrmrOptional[str] | OmitrOptional[float] | OmitrDrrErrFrrGrrzStream[TaskGroupEventsResponse])rZrmrrrrrrrrOptional[Literal['queued', 'action_required', 'running', 'completed', 'failed', 'cancelling', 'cancelled']] | OmitrDrrErrFrrGrrz Stream[TaskGroupGetRunsResponse]rrmrZrmrDrrErrFrrGrrr'__name__ __module__ __qualname____firstlineno____doc__rr:r@rrrSr`r}rrr__static_attributes__rr<r9r/r/(s 66<<IM)-$("&;D  F  &  "     9     P)-$("&;D  &  "   9   L'+<@04)-$("&;D@ @ ( @ $ @ : @ .@ &@ "@  @ 9@  @ L/3.2)-$("&;D3 3 , 3 , 3 &3 "3  3 93  )3 r&*&*.2)-$("&;D!@ @ # @ $ @ , @ @ &@ "@  @ 9!@ " *#@ R)-$("&;D' '  ' &' "'  ' 9'  ' ' r<c \rSrSrSr\SSj5r\SSj5r\SSS\ S.SSjjr SSS\ S.SS jjr \\\SSS\ S .SS jjr \\SSS\ S .SS jjr \\\\SSS\ S.SSjjrSSS\ S.SSjjrSrg)r0ior3c[U5$r5)%AsyncTaskGroupResourceWithRawResponser7s r9r:(AsyncTaskGroupResource.with_raw_response}s5T::r<c[U5$r>)+AsyncTaskGroupResourceWithStreamingResponser7s r9r@.AsyncTaskGroupResource.with_streaming_responses;4@@r<NrBc # URS[SU0[R5IShvN [ X#XES9[ S9IShvN $NN7f)rIrJrCNrKrL)rPrr rQr&r(rRs r9rSAsyncTaskGroupResource.createsY2ZZ ,j(-CE]EsEstt(+Q[     t s!,AA AA A ArKc # U(d[SU<35eUR[SUS9[X#XES9[S9IShvN $N7f)rVrWrXrYrKr[Nr\r_s r9r`AsyncTaskGroupResource.retrieves].[\i[lmn nYY .rsrtrurYrvNrcrxrL) r]rrrzrrPrrrr{r&r+r|s r9r}AsyncTaskGroupResource.add_runssN[\i[lmn n S[\aSbSb8O8O0Ohqrs " ZZ AQ^ _,$):+AA )+'%1%~68R8i8i )%     s6BCC +C?CCCCCCrc8# U(d[SU<35eSS0U=(d 0EnUR[SUS9[UUUU[ UUS.[ R 5IShvN S9[[[5S [[S 9IShvN $N0N7f) rrWrrrrYrNrxTr) r]r^rr&rrrr rr-r%rs r9rAsyncTaskGroupResource.eventss8[\i[lmn n!#6P=;NBP YY CS` a(+'%1)6'2-BB  ,"#:;'    s$A#B%B&+BBBBrc<# U(d[SU<35eSS0U=(d 0EnUR[SUS9[UUUU [ UUUUS.[ R 5IShvN S9[[[5S [[S 9IShvN $N0N7f) rrWrrrurYrNrxTr) r]r^rr&rrrr rr.r%rs r9rAsyncTaskGroupResource.get_runsJsN[\i[lmn n!#6P=;NBP YY AQ^ _(+'%1)6*8)6"(  /EE -"#;<+    s$A%B'B(+BBBBc # U(d[SU<35eU(d[SU<35eUR[SX!S9[X4XVS9[S9IShvN $N7f)rrWrrrrKr[Nrrs r9r#AsyncTaskGroupResource.retrieve_runsv:[\i[lmn nTU[T^_` `YY JZg w(+Q[     sAAAAr)rr)rrrrr)rZrmrrrrrDrrErrFrrGrrz$AsyncStream[TaskGroupEventsResponse])rZrmrrrrrrrrrDrrErrFrrGrrz%AsyncStream[TaskGroupGetRunsResponse]rrrr<r9r0r0os ;;AAIM)-$("&;D  F  &  "     9     P)-$("&;D  &  "   9   L'+<@04)-$("&;D@ @ ( @ $ @ : @ .@ &@ "@  @ 9@  @ L/3.2)-$("&;D3 3 , 3 , 3 &3 "3  3 93  .3 r&*&*.2)-$("&;D!@ @ # @ $ @ , @ @ &@ "@  @ 9!@ " /#@ R)-$("&;D' '  ' &' "'  ' 9'  ' ' r<c\rSrSrSSjrSrg)r6icHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ulgrk) _task_groupr rSr`r}rrrr8 task_groups r9__init__)TaskGroupResourceWithRawResponse.__init__s%-     0     0     .     0     4  # # r<rr}rSrrr`rNrr/rNonerrrrrrrr<r9r6r6 r<r6c\rSrSrSSjrSrg)ricHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ulgrk)rr"rSr`r}rrrrs r9r.AsyncTaskGroupResourceWithRawResponse.__init__s%3     6     6     4     6     :  # # r<rNrr0rrrrr<r9rrrr<rc\rSrSrSSjrSrg)r?icHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ulgrk)rr!rSr`r}rrrrs r9r/TaskGroupResourceWithStreamingResponse.__init__s%2     5     5     3     5     9  # # r<rNrrrr<r9r?r?rr<r?c\rSrSrSSjrSrg)ricHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ulgrk)rr#rSr`r}rrrrs r9r4AsyncTaskGroupResourceWithStreamingResponse.__init__s%8     ;     ;     9     ;     ?  # # r<rNrrrr<r9rrrr<r)F __future__rtypingrrrrrr r typing_extensionsr httpxtypesr rrr_typesrrrrrrr_utilsrrrrr_compatr _resourcerr _responser r!r"r# _streamingr$r% _base_clientr&types.task_runr'types.task_groupr(types.run_input_paramr)types.task_spec_paramr*types.task_group_run_responser+types.beta.parallel_beta_paramr, types.task_group_events_responser-"types.task_group_get_runs_responser.__all__r/r0r6rr?rrr<r9rs#CCC%  KJJee%9 -/$(11@>FI  8 9D D N D -D N   0  0  0  r<