Skip to content

Commit 1b7c8ff

Browse files
chore(internal): codegen related update
1 parent 1e1d858 commit 1b7c8ff

6 files changed

Lines changed: 184 additions & 0 deletions

File tree

src/parallel/_client.py

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,11 @@ def __init__(
104104

105105
@cached_property
106106
def task_run(self) -> TaskRunResource:
107+
"""The Task API executes web research and extraction tasks.
108+
109+
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.
110+
- Output metadata: citations, excerpts, reasoning, and confidence per field
111+
"""
107112
from .resources.task_run import TaskRunResource
108113

109114
return TaskRunResource(self)
@@ -284,6 +289,11 @@ def __init__(
284289

285290
@cached_property
286291
def task_run(self) -> AsyncTaskRunResource:
292+
"""The Task API executes web research and extraction tasks.
293+
294+
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.
295+
- Output metadata: citations, excerpts, reasoning, and confidence per field
296+
"""
287297
from .resources.task_run import AsyncTaskRunResource
288298

289299
return AsyncTaskRunResource(self)
@@ -415,6 +425,11 @@ def __init__(self, client: Parallel) -> None:
415425

416426
@cached_property
417427
def task_run(self) -> task_run.TaskRunResourceWithRawResponse:
428+
"""The Task API executes web research and extraction tasks.
429+
430+
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.
431+
- Output metadata: citations, excerpts, reasoning, and confidence per field
432+
"""
418433
from .resources.task_run import TaskRunResourceWithRawResponse
419434

420435
return TaskRunResourceWithRawResponse(self._client.task_run)
@@ -434,6 +449,11 @@ def __init__(self, client: AsyncParallel) -> None:
434449

435450
@cached_property
436451
def task_run(self) -> task_run.AsyncTaskRunResourceWithRawResponse:
452+
"""The Task API executes web research and extraction tasks.
453+
454+
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.
455+
- Output metadata: citations, excerpts, reasoning, and confidence per field
456+
"""
437457
from .resources.task_run import AsyncTaskRunResourceWithRawResponse
438458

439459
return AsyncTaskRunResourceWithRawResponse(self._client.task_run)
@@ -453,6 +473,11 @@ def __init__(self, client: Parallel) -> None:
453473

454474
@cached_property
455475
def task_run(self) -> task_run.TaskRunResourceWithStreamingResponse:
476+
"""The Task API executes web research and extraction tasks.
477+
478+
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.
479+
- Output metadata: citations, excerpts, reasoning, and confidence per field
480+
"""
456481
from .resources.task_run import TaskRunResourceWithStreamingResponse
457482

458483
return TaskRunResourceWithStreamingResponse(self._client.task_run)
@@ -472,6 +497,11 @@ def __init__(self, client: AsyncParallel) -> None:
472497

473498
@cached_property
474499
def task_run(self) -> task_run.AsyncTaskRunResourceWithStreamingResponse:
500+
"""The Task API executes web research and extraction tasks.
501+
502+
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.
503+
- Output metadata: citations, excerpts, reasoning, and confidence per field
504+
"""
475505
from .resources.task_run import AsyncTaskRunResourceWithStreamingResponse
476506

477507
return AsyncTaskRunResourceWithStreamingResponse(self._client.task_run)

src/parallel/resources/beta/beta.py

Lines changed: 102 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,31 @@
5757
class BetaResource(SyncAPIResource):
5858
@cached_property
5959
def task_run(self) -> TaskRunResource:
60+
"""The Task API executes web research and extraction tasks.
61+
62+
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.
63+
- Output metadata: citations, excerpts, reasoning, and confidence per field
64+
"""
6065
return TaskRunResource(self._client)
6166

6267
@cached_property
6368
def task_group(self) -> TaskGroupResource:
69+
"""
70+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
71+
- Submit hundreds or thousands of Tasks as a single group
72+
- Observe group progress and receive results as they complete
73+
- Real-time updates via Server-Sent Events (SSE)
74+
- Add tasks to an existing group while it is running
75+
- Group-level retry and error aggregation
76+
Status: beta and subject to change.
77+
"""
6478
return TaskGroupResource(self._client)
6579

6680
@cached_property
6781
def findall(self) -> FindAllResource:
82+
"""
83+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
84+
"""
6885
return FindAllResource(self._client)
6986

7087
@cached_property
@@ -265,14 +282,31 @@ def search(
265282
class AsyncBetaResource(AsyncAPIResource):
266283
@cached_property
267284
def task_run(self) -> AsyncTaskRunResource:
285+
"""The Task API executes web research and extraction tasks.
286+
287+
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.
288+
- Output metadata: citations, excerpts, reasoning, and confidence per field
289+
"""
268290
return AsyncTaskRunResource(self._client)
269291

270292
@cached_property
271293
def task_group(self) -> AsyncTaskGroupResource:
294+
"""
295+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
296+
- Submit hundreds or thousands of Tasks as a single group
297+
- Observe group progress and receive results as they complete
298+
- Real-time updates via Server-Sent Events (SSE)
299+
- Add tasks to an existing group while it is running
300+
- Group-level retry and error aggregation
301+
Status: beta and subject to change.
302+
"""
272303
return AsyncTaskGroupResource(self._client)
273304

274305
@cached_property
275306
def findall(self) -> AsyncFindAllResource:
307+
"""
308+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
309+
"""
276310
return AsyncFindAllResource(self._client)
277311

278312
@cached_property
@@ -483,14 +517,31 @@ def __init__(self, beta: BetaResource) -> None:
483517

484518
@cached_property
485519
def task_run(self) -> TaskRunResourceWithRawResponse:
520+
"""The Task API executes web research and extraction tasks.
521+
522+
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.
523+
- Output metadata: citations, excerpts, reasoning, and confidence per field
524+
"""
486525
return TaskRunResourceWithRawResponse(self._beta.task_run)
487526

488527
@cached_property
489528
def task_group(self) -> TaskGroupResourceWithRawResponse:
529+
"""
530+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
531+
- Submit hundreds or thousands of Tasks as a single group
532+
- Observe group progress and receive results as they complete
533+
- Real-time updates via Server-Sent Events (SSE)
534+
- Add tasks to an existing group while it is running
535+
- Group-level retry and error aggregation
536+
Status: beta and subject to change.
537+
"""
490538
return TaskGroupResourceWithRawResponse(self._beta.task_group)
491539

492540
@cached_property
493541
def findall(self) -> FindAllResourceWithRawResponse:
542+
"""
543+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
544+
"""
494545
return FindAllResourceWithRawResponse(self._beta.findall)
495546

496547

@@ -507,14 +558,31 @@ def __init__(self, beta: AsyncBetaResource) -> None:
507558

508559
@cached_property
509560
def task_run(self) -> AsyncTaskRunResourceWithRawResponse:
561+
"""The Task API executes web research and extraction tasks.
562+
563+
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.
564+
- Output metadata: citations, excerpts, reasoning, and confidence per field
565+
"""
510566
return AsyncTaskRunResourceWithRawResponse(self._beta.task_run)
511567

512568
@cached_property
513569
def task_group(self) -> AsyncTaskGroupResourceWithRawResponse:
570+
"""
571+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
572+
- Submit hundreds or thousands of Tasks as a single group
573+
- Observe group progress and receive results as they complete
574+
- Real-time updates via Server-Sent Events (SSE)
575+
- Add tasks to an existing group while it is running
576+
- Group-level retry and error aggregation
577+
Status: beta and subject to change.
578+
"""
514579
return AsyncTaskGroupResourceWithRawResponse(self._beta.task_group)
515580

516581
@cached_property
517582
def findall(self) -> AsyncFindAllResourceWithRawResponse:
583+
"""
584+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
585+
"""
518586
return AsyncFindAllResourceWithRawResponse(self._beta.findall)
519587

520588

@@ -531,14 +599,31 @@ def __init__(self, beta: BetaResource) -> None:
531599

532600
@cached_property
533601
def task_run(self) -> TaskRunResourceWithStreamingResponse:
602+
"""The Task API executes web research and extraction tasks.
603+
604+
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.
605+
- Output metadata: citations, excerpts, reasoning, and confidence per field
606+
"""
534607
return TaskRunResourceWithStreamingResponse(self._beta.task_run)
535608

536609
@cached_property
537610
def task_group(self) -> TaskGroupResourceWithStreamingResponse:
611+
"""
612+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
613+
- Submit hundreds or thousands of Tasks as a single group
614+
- Observe group progress and receive results as they complete
615+
- Real-time updates via Server-Sent Events (SSE)
616+
- Add tasks to an existing group while it is running
617+
- Group-level retry and error aggregation
618+
Status: beta and subject to change.
619+
"""
538620
return TaskGroupResourceWithStreamingResponse(self._beta.task_group)
539621

540622
@cached_property
541623
def findall(self) -> FindAllResourceWithStreamingResponse:
624+
"""
625+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
626+
"""
542627
return FindAllResourceWithStreamingResponse(self._beta.findall)
543628

544629

@@ -555,12 +640,29 @@ def __init__(self, beta: AsyncBetaResource) -> None:
555640

556641
@cached_property
557642
def task_run(self) -> AsyncTaskRunResourceWithStreamingResponse:
643+
"""The Task API executes web research and extraction tasks.
644+
645+
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.
646+
- Output metadata: citations, excerpts, reasoning, and confidence per field
647+
"""
558648
return AsyncTaskRunResourceWithStreamingResponse(self._beta.task_run)
559649

560650
@cached_property
561651
def task_group(self) -> AsyncTaskGroupResourceWithStreamingResponse:
652+
"""
653+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
654+
- Submit hundreds or thousands of Tasks as a single group
655+
- Observe group progress and receive results as they complete
656+
- Real-time updates via Server-Sent Events (SSE)
657+
- Add tasks to an existing group while it is running
658+
- Group-level retry and error aggregation
659+
Status: beta and subject to change.
660+
"""
562661
return AsyncTaskGroupResourceWithStreamingResponse(self._beta.task_group)
563662

564663
@cached_property
565664
def findall(self) -> AsyncFindAllResourceWithStreamingResponse:
665+
"""
666+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
667+
"""
566668
return AsyncFindAllResourceWithStreamingResponse(self._beta.findall)

src/parallel/resources/beta/findall.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,10 @@
5353

5454

5555
class FindAllResource(SyncAPIResource):
56+
"""
57+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
58+
"""
59+
5660
@cached_property
5761
def with_raw_response(self) -> FindAllResourceWithRawResponse:
5862
"""
@@ -594,6 +598,10 @@ def schema(
594598

595599

596600
class AsyncFindAllResource(AsyncAPIResource):
601+
"""
602+
The FindAll API discovers and evaluates entities that match complex criteria from natural language objectives. Submit a high-level goal and the service automatically generates structured match conditions, discovers relevant candidates, and evaluates each against the criteria. Returns comprehensive results with detailed reasoning, citations, and confidence scores for each match decision. Streaming events and webhooks are supported.
603+
"""
604+
597605
@cached_property
598606
def with_raw_response(self) -> AsyncFindAllResourceWithRawResponse:
599607
"""

src/parallel/resources/beta/task_group.py

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,16 @@
3838

3939

4040
class TaskGroupResource(SyncAPIResource):
41+
"""
42+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
43+
- Submit hundreds or thousands of Tasks as a single group
44+
- Observe group progress and receive results as they complete
45+
- Real-time updates via Server-Sent Events (SSE)
46+
- Add tasks to an existing group while it is running
47+
- Group-level retry and error aggregation
48+
Status: beta and subject to change.
49+
"""
50+
4151
@cached_property
4252
def with_raw_response(self) -> TaskGroupResourceWithRawResponse:
4353
"""
@@ -314,6 +324,16 @@ def get_runs(
314324

315325

316326
class AsyncTaskGroupResource(AsyncAPIResource):
327+
"""
328+
The Task Group API is currently in beta and enables batch execution of many independent Task runs with group-level monitoring and failure handling.
329+
- Submit hundreds or thousands of Tasks as a single group
330+
- Observe group progress and receive results as they complete
331+
- Real-time updates via Server-Sent Events (SSE)
332+
- Add tasks to an existing group while it is running
333+
- Group-level retry and error aggregation
334+
Status: beta and subject to change.
335+
"""
336+
317337
@cached_property
318338
def with_raw_response(self) -> AsyncTaskGroupResourceWithRawResponse:
319339
"""

0 commit comments

Comments
 (0)