fix(api): Make beta headers optional in /v1beta/extract

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 13
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/parallel-web%2Fparallel-sdk-de8ef7fc6a3509bf74c63258ebd4c110fc0c7669ebdbeaf7c8adcbf359f43a56.yml
-openapi_spec_hash: a7fd6467be3ff6c3037d29e87c172260
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/parallel-web%2Fparallel-sdk-77649b8f6d46525bfb9fe6d0ec115b1c639d41fffae2a513fa8e9fe5d700f069.yml
+openapi_spec_hash: 9e34db58728d2541dc23144262a66a71
 config_hash: 677d555754b79eb922f6bf64bccd9559

src/parallel/resources/beta/beta.py

@@ -78,12 +78,12 @@ def extract(
         self,
         *,
         urls: SequenceNotStr[str],
-        betas: List[ParallelBetaParam],
         excerpts: beta_extract_params.Excerpts | Omit = omit,
         fetch_policy: Optional[FetchPolicyParam] | Omit = omit,
         full_content: beta_extract_params.FullContent | Omit = omit,
         objective: Optional[str] | Omit = omit,
         search_queries: Optional[SequenceNotStr[str]] | Omit = omit,
+        betas: List[ParallelBetaParam] | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -98,8 +98,6 @@ def extract(
         `search-extract-2025-10-10`.
 
         Args:
-          betas: Optional header to specify the beta version(s) to enable.
-
           excerpts: Include excerpts from each URL relevant to the search objective and queries.
               Note that if neither objective nor search_queries is provided, excerpts are
               redundant with full content.
@@ -117,6 +115,8 @@ def extract(
 
           search_queries: If provided, focuses extracted content on the specified keyword search queries.
 
+          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
@@ -126,10 +126,16 @@ def extract(
           timeout: Override the client-level default timeout for this request, in seconds
         """
         extra_headers = {
-            "parallel-beta": ",".join(chain((str(e) for e in betas), ["search-extract-2025-10-10"])),
+            **strip_not_given(
+                {
+                    "parallel-beta": ",".join(chain((str(e) for e in betas), ["search-extract-2025-10-10"]))
+                    if is_given(betas)
+                    else not_given
+                }
+            ),
             **(extra_headers or {}),
         }
-        extra_headers.update({"parallel-beta": "search-extract-2025-10-10"})
+        extra_headers = {"parallel-beta": "search-extract-2025-10-10", **(extra_headers or {})}
         return self._post(
             "/v1beta/extract",
             body=maybe_transform(
@@ -284,12 +290,12 @@ async def extract(
         self,
         *,
         urls: SequenceNotStr[str],
-        betas: List[ParallelBetaParam],
         excerpts: beta_extract_params.Excerpts | Omit = omit,
         fetch_policy: Optional[FetchPolicyParam] | Omit = omit,
         full_content: beta_extract_params.FullContent | Omit = omit,
         objective: Optional[str] | Omit = omit,
         search_queries: Optional[SequenceNotStr[str]] | Omit = omit,
+        betas: List[ParallelBetaParam] | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -304,8 +310,6 @@ async def extract(
         `search-extract-2025-10-10`.
 
         Args:
-          betas: Optional header to specify the beta version(s) to enable.
-
           excerpts: Include excerpts from each URL relevant to the search objective and queries.
               Note that if neither objective nor search_queries is provided, excerpts are
               redundant with full content.
@@ -323,6 +327,8 @@ async def extract(
 
           search_queries: If provided, focuses extracted content on the specified keyword search queries.
 
+          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
@@ -332,10 +338,16 @@ async def extract(
           timeout: Override the client-level default timeout for this request, in seconds
         """
         extra_headers = {
-            "parallel-beta": ",".join(chain((str(e) for e in betas), ["search-extract-2025-10-10"])),
+            **strip_not_given(
+                {
+                    "parallel-beta": ",".join(chain((str(e) for e in betas), ["search-extract-2025-10-10"]))
+                    if is_given(betas)
+                    else not_given
+                }
+            ),
             **(extra_headers or {}),
         }
-        extra_headers.update({"parallel-beta": "search-extract-2025-10-10"})
+        extra_headers = {"parallel-beta": "search-extract-2025-10-10", **(extra_headers or {})}
         return await self._post(
             "/v1beta/extract",
             body=await async_maybe_transform(

src/parallel/types/beta/beta_extract_params.py

@@ -17,9 +17,6 @@
 class BetaExtractParams(TypedDict, total=False):
     urls: Required[SequenceNotStr[str]]
 
-    betas: Required[Annotated[List[ParallelBetaParam], PropertyInfo(alias="parallel-beta")]]
-    """Optional header to specify the beta version(s) to enable."""
-
     excerpts: Excerpts
     """Include excerpts from each URL relevant to the search objective and queries.
 
@@ -48,6 +45,9 @@ class BetaExtractParams(TypedDict, total=False):
     search_queries: Optional[SequenceNotStr[str]]
     """If provided, focuses extracted content on the specified keyword search queries."""
 
+    betas: Annotated[List[ParallelBetaParam], PropertyInfo(alias="parallel-beta")]
+    """Optional header to specify the beta version(s) to enable."""
+
 
 Excerpts: TypeAlias = Union[bool, ExcerptSettingsParam]
 

tests/api_resources/test_beta.py

@@ -24,15 +24,13 @@ class TestBeta:
     def test_method_extract(self, client: Parallel) -> None:
         beta = client.beta.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         )
         assert_matches_type(ExtractResponse, beta, path=["response"])
 
     @parametrize
     def test_method_extract_with_all_params(self, client: Parallel) -> None:
         beta = client.beta.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
             excerpts=True,
             fetch_policy={
                 "disable_cache_fallback": True,
@@ -42,14 +40,14 @@ def test_method_extract_with_all_params(self, client: Parallel) -> None:
             full_content=True,
             objective="objective",
             search_queries=["string"],
+            betas=["mcp-server-2025-07-17"],
         )
         assert_matches_type(ExtractResponse, beta, path=["response"])
 
     @parametrize
     def test_raw_response_extract(self, client: Parallel) -> None:
         response = client.beta.with_raw_response.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         )
 
         assert response.is_closed is True
@@ -61,7 +59,6 @@ def test_raw_response_extract(self, client: Parallel) -> None:
     def test_streaming_response_extract(self, client: Parallel) -> None:
         with client.beta.with_streaming_response.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         ) as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
@@ -129,15 +126,13 @@ class TestAsyncBeta:
     async def test_method_extract(self, async_client: AsyncParallel) -> None:
         beta = await async_client.beta.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         )
         assert_matches_type(ExtractResponse, beta, path=["response"])
 
     @parametrize
     async def test_method_extract_with_all_params(self, async_client: AsyncParallel) -> None:
         beta = await async_client.beta.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
             excerpts=True,
             fetch_policy={
                 "disable_cache_fallback": True,
@@ -147,14 +142,14 @@ async def test_method_extract_with_all_params(self, async_client: AsyncParallel)
             full_content=True,
             objective="objective",
             search_queries=["string"],
+            betas=["mcp-server-2025-07-17"],
         )
         assert_matches_type(ExtractResponse, beta, path=["response"])
 
     @parametrize
     async def test_raw_response_extract(self, async_client: AsyncParallel) -> None:
         response = await async_client.beta.with_raw_response.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         )
 
         assert response.is_closed is True
@@ -166,7 +161,6 @@ async def test_raw_response_extract(self, async_client: AsyncParallel) -> None:
     async def test_streaming_response_extract(self, async_client: AsyncParallel) -> None:
         async with async_client.beta.with_streaming_response.extract(
             urls=["string"],
-            betas=["mcp-server-2025-07-17"],
         ) as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"