style: apply ruff lint and format to existing test/doc code

Address pre-existing ruff findings that were masked by the protoc build
failure in the lint job. Manual fixes in 5 files:

- tests/integration/test_assistants{,_async}.py: B904 add `from None`
  to AssertionError raises inside except blocks
- tests/unit/test_http_error_parsing.py: RUF059 rename unused tuple
  unpack targets to `_code`/`_error_code`; SIM201 `not msg == ""` →
  `msg != ""`
- tests/unit/preview/test_async_parity.py: F841 remove unused local
- tests/unit/models/assistant/test_streaming_display.py: E402 hoist
  AsyncChatCompletionStream import to the top of the file

Plus `ruff format` auto-applied to 28 files of pre-existing format
drift. No behavioral changes.

Author: jhamon

pinecone/_internal/indexes_helpers.py

@@ -114,9 +114,7 @@ def validate_create_inputs(
         raise ValidationError("spec dict must contain a 'serverless', 'pod', or 'byoc' key")
 
     if dimension is not None and not isinstance(dimension, int):
-        raise PineconeTypeError(
-            f"dimension must be an integer, got {type(dimension).__name__!r}"
-        )
+        raise PineconeTypeError(f"dimension must be an integer, got {type(dimension).__name__!r}")
 
     resolved_vt = resolve_enum_value(vector_type)
     if resolved_vt == "sparse" and dimension is not None:

tests/integration/test_admin.py

@@ -94,7 +94,9 @@ def test_admin_init_validation_whitespace_only_client_id(monkeypatch: pytest.Mon
 
 
 @pytest.mark.integration
-def test_admin_init_validation_whitespace_only_client_secret(monkeypatch: pytest.MonkeyPatch) -> None:
+def test_admin_init_validation_whitespace_only_client_secret(
+    monkeypatch: pytest.MonkeyPatch,
+) -> None:
     """Admin() raises PineconeValueError for a whitespace-only client_secret.
 
     Env vars are cleared to prevent the fallback from masking the kwarg value.

tests/integration/test_assistants.py

@@ -1092,7 +1092,7 @@ def test_context_retrieval_validation_rest(client: Pinecone) -> None:
         raise AssertionError(
             "context() raised PineconeValueError when query='' and messages is non-empty — "
             "empty string should be treated as not provided, leaving messages as the sole input"
-        )
+        ) from None
     except Exception:
         # Any other exception (ApiError, NotFoundError, etc.) is acceptable here —
         # the assistant does not exist and the API will reject the request.

tests/integration/test_assistants_async.py

@@ -1160,7 +1160,7 @@ async def test_context_retrieval_validation_async(async_client: AsyncPinecone) -
         raise AssertionError(
             "context() raised PineconeValueError when query='' and messages is non-empty — "
             "empty string should be treated as not provided, leaving messages as the sole input"
-        )
+        ) from None
     except Exception:
         # Any other exception (ApiError, NotFoundError, etc.) is acceptable here —
         # the assistant does not exist and the API will reject the request.

tests/perf/test_grpc_throughput.py

@@ -10,8 +10,7 @@
 
 QUERY_RESPONSE = {
     "matches": [
-        {"id": f"v{i}", "score": 0.9 - i * 0.01, "values": [], "metadata": None}
-        for i in range(100)
+        {"id": f"v{i}", "score": 0.9 - i * 0.01, "values": [], "metadata": None} for i in range(100)
     ],
     "namespace": "ns",
     "usage": {"read_units": 1},

tests/smoke/helpers.py

@@ -128,8 +128,7 @@ def wait_for_pod_warmup(
             last_exc = exc
         time.sleep(interval)
     raise TimeoutError(
-        f"Pod index did not warm up within {timeout}s "
-        f"(last fetch error: {last_exc!r})"
+        f"Pod index did not warm up within {timeout}s (last fetch error: {last_exc!r})"
     )
 
 
@@ -157,11 +156,8 @@ def capture_deprecation_warning(expected_substring: str = "") -> Iterator[list[A
     relevant = [r for r in records if issubclass(r.category, DeprecationWarning)]
     if not relevant:
         raise AssertionError("Expected at least one DeprecationWarning, got none")
-    if expected_substring and not any(
-        expected_substring in str(r.message) for r in relevant
-    ):
+    if expected_substring and not any(expected_substring in str(r.message) for r in relevant):
         messages = [str(r.message) for r in relevant]
         raise AssertionError(
-            f"No captured DeprecationWarning contained {expected_substring!r}. "
-            f"Got: {messages}"
+            f"No captured DeprecationWarning contained {expected_substring!r}. Got: {messages}"
         )

tests/smoke/test_assistants_async.py

@@ -89,9 +89,7 @@ async def status_check() -> str:
         assert multimodal_file.status == "Available"
 
         # ----- describe_file / list_files / list_files_page -----
-        d_file = await pc.assistants.describe_file(
-            assistant_name=name, file_id=text_file.id
-        )
+        d_file = await pc.assistants.describe_file(assistant_name=name, file_id=text_file.id)
         assert d_file.id == text_file.id
 
         all_files = await pc.assistants.list_files(assistant_name=name).to_list()
@@ -161,9 +159,7 @@ async def status_check() -> str:
         assert via_call.name == name
 
         # ----- delete_file -----
-        await pc.assistants.delete_file(
-            assistant_name=name, file_id=text_file.id
-        )
+        await pc.assistants.delete_file(assistant_name=name, file_id=text_file.id)
     finally:
         await async_cleanup_resource(
             lambda: pc.assistants.delete(name=name),

tests/smoke/test_assistants_sync.py

@@ -93,9 +93,7 @@ def test_assistants_smoke(client: Pinecone) -> None:
         assert multimodal_file.status == "Available"
 
         # ----- describe_file / list_files / list_files_page -----
-        d_file = client.assistants.describe_file(
-            assistant_name=name, file_id=text_file.id
-        )
+        d_file = client.assistants.describe_file(assistant_name=name, file_id=text_file.id)
         assert d_file.id == text_file.id
 
         all_files = client.assistants.list_files(assistant_name=name).to_list()
@@ -163,9 +161,7 @@ def test_assistants_smoke(client: Pinecone) -> None:
         assert via_call.name == name
 
         # ----- delete_file (one of them) -----
-        client.assistants.delete_file(
-            assistant_name=name, file_id=text_file.id
-        )
+        client.assistants.delete_file(assistant_name=name, file_id=text_file.id)
     finally:
         # delete assistant first (tears down files server-side too)
         cleanup_resource(

tests/smoke/test_deprecated_shims_async.py

@@ -76,9 +76,7 @@ async def test_deprecated_shims_smoke_async(api_key: str) -> None:
         assert exists is True
 
         with capture_deprecation_warning("configure_index"):
-            await async_client.configure_index(
-                serverless_name, tags={"env": "smoke-async"}
-            )
+            await async_client.configure_index(serverless_name, tags={"env": "smoke-async"})
 
         # ----- IndexAsyncio() factory (constructor only) -----
         with capture_deprecation_warning("IndexAsyncio"):
@@ -109,9 +107,7 @@ async def test_deprecated_shims_smoke_async(api_key: str) -> None:
             jobs = await async_client.list_restore_jobs(limit=10)
         if jobs.data:
             with capture_deprecation_warning("describe_restore_job"):
-                await async_client.describe_restore_job(
-                    job_id=jobs.data[0].restore_job_id
-                )
+                await async_client.describe_restore_job(job_id=jobs.data[0].restore_job_id)
         else:
             with capture_deprecation_warning("describe_restore_job"):
                 with pytest.raises((NotFoundError, PineconeApiException)):

tests/smoke/test_pod_collections_async.py

@@ -40,6 +40,7 @@ async def _async_wait_for_collection_deletion(
         await asyncio.sleep(interval)
     print(f"  WARNING: collection {name} still present after {timeout}s")
 
+
 POD_ENV = "us-east-1-aws"
 DIM = 8
 NAMESPACE = "smoke-pod-ns-async"
@@ -72,8 +73,7 @@ async def _async_wait_for_pod_warmup(
             last_exc = exc
         await asyncio.sleep(interval)
     raise TimeoutError(
-        f"Pod index did not warm up within {timeout}s "
-        f"(last fetch error: {last_exc!r})"
+        f"Pod index did not warm up within {timeout}s (last fetch error: {last_exc!r})"
     )
 
 
@@ -97,13 +97,9 @@ async def test_pod_collections_smoke_async(api_key: str) -> None:
         idx1 = pc.index(name=pod1_name)
         try:
             await idx1.upsert(vectors=[_vec(0)], namespace=NAMESPACE)
-            await _async_wait_for_pod_warmup(
-                idx1, "p0", namespace=NAMESPACE, timeout=600
-            )
+            await _async_wait_for_pod_warmup(idx1, "p0", namespace=NAMESPACE, timeout=600)
 
-            await idx1.upsert(
-                vectors=[_vec(i) for i in range(1, 6)], namespace=NAMESPACE
-            )
+            await idx1.upsert(vectors=[_vec(i) for i in range(1, 6)], namespace=NAMESPACE)
             await async_wait_for_vector_count(idx1, NAMESPACE, expected=6, timeout=120)
 
             q = await idx1.query(
@@ -148,9 +144,7 @@ async def col_status() -> object:
 
         idx2 = pc.index(name=pod2_name)
         try:
-            await _async_wait_for_pod_warmup(
-                idx2, "p0", namespace=NAMESPACE, timeout=300
-            )
+            await _async_wait_for_pod_warmup(idx2, "p0", namespace=NAMESPACE, timeout=300)
             stats = await idx2.describe_index_stats()
             ns = stats.namespaces.get(NAMESPACE)
             assert ns is not None