fix: avoid decoding demo blob compression twice; release 0.46.1

Author: rustyconover

packages/vgi-fixtures/pyproject.toml

@@ -8,7 +8,7 @@
 # and the conformance suite import it by its normal `vgi._test_fixtures` path.
 [project]
 name = "vgi-fixtures"
-version = "0.46.0"
+version = "0.46.1"
 description = "Example/test VGI worker modules and entry points (not for production use)"
 readme = "README.md"
 # Local copy of the repo-root LICENSE (kept in sync): the build can't reach

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "vgi-python"
-version = "0.46.0"
+version = "0.46.1"
 description = "Vector Gateway Interface - Connect DuckDB to external programs via Apache Arrow"
 readme = "README.md"
 keywords = [

tests/test_http_demo_storage.py

@@ -294,6 +294,12 @@ def test_demo_output_offload_large_response(compression: str, expected_extension
         assert source.decode().endswith(expected_extension)
         assert fetch_ms is not None
 
+        # Advertising both headers causes clients that decode standard HTTP
+        # compression to try to decompress the same external result twice.
+        blob_headers = httpx2.head(source.decode(), timeout=30.0).headers
+        assert "X-VGI-Content-Encoding" not in blob_headers
+        assert blob_headers.get("Content-Encoding") == (None if compression == "none" else compression)
+
 
 @pytest.mark.parametrize("compression", ["none", "zstd", "gzip"])
 def test_demo_input_upload_url_then_exchange(compression: str) -> None:

uv.lock

@@ -118,8 +118,9 @@ def on_get(self, req: Any, resp: Any, blob_id: str) -> None:  # noqa: D102
         resp.content_type = "application/octet-stream"
         resp.set_header("Accept-Ranges", "none")
         if content_encoding:
+            # HTTP clients decode this standard header automatically. Sending
+            # the custom VGI header too makes clients try to decode it again.
             resp.set_header("Content-Encoding", content_encoding)
-            resp.set_header("X-VGI-Content-Encoding", content_encoding)
 
     def on_head(self, req: Any, resp: Any, blob_id: str) -> None:  # noqa: D102
         # Mirror on_get headers (Content-Length/-Type/-Encoding) without a body.
@@ -137,7 +138,6 @@ def on_head(self, req: Any, resp: Any, blob_id: str) -> None:  # noqa: D102
         resp.set_header("Accept-Ranges", "none")
         if content_encoding:
             resp.set_header("Content-Encoding", content_encoding)
-            resp.set_header("X-VGI-Content-Encoding", content_encoding)
 
     def on_put(self, req: Any, resp: Any, blob_id: str) -> None:  # noqa: D102
         # vgi_rpc's _CompressionMiddleware drains ``req.bounded_stream`` when