feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 107
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/datamini%2Fasktable-6e642a3ad811f8391e0f6f9644177b6d75093111e0b26753ab1be472571e55c1.yml
-openapi_spec_hash: fb38fedd6a15285540b1eb45521518a8
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/datamini%2Fasktable-18a8c8242c5e5c5886a2a31908480384759e5c2239664797372c109538408917.yml
+openapi_spec_hash: a7c5019fc13696353a6a97d4a68cf729
 config_hash: acdf4142177ed1932c2d82372693f811

pyproject.toml

@@ -39,7 +39,7 @@ Homepage = "https://github.com/DataMini/asktable-python"
 Repository = "https://github.com/DataMini/asktable-python"
 
 [project.optional-dependencies]
-aiohttp = ["aiohttp", "httpx_aiohttp>=0.1.8"]
+aiohttp = ["aiohttp", "httpx_aiohttp>=0.1.9"]
 
 [tool.rye]
 managed = true

requirements-dev.lock

@@ -56,7 +56,7 @@ httpx==0.28.1
     # via asktable
     # via httpx-aiohttp
     # via respx
-httpx-aiohttp==0.1.8
+httpx-aiohttp==0.1.9
     # via asktable
 idna==3.4
     # via anyio

requirements.lock

@@ -43,7 +43,7 @@ httpcore==1.0.9
 httpx==0.28.1
     # via asktable
     # via httpx-aiohttp
-httpx-aiohttp==0.1.8
+httpx-aiohttp==0.1.9
     # via asktable
 idna==3.4
     # via anyio

src/asktable/_streaming.py

@@ -57,9 +57,8 @@ def __stream__(self) -> Iterator[_T]:
         for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -121,9 +120,8 @@ async def __stream__(self) -> AsyncIterator[_T]:
         async for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        async for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        await response.aclose()
 
     async def __aenter__(self) -> Self:
         return self

src/asktable/_utils/_utils.py

@@ -133,7 +133,7 @@ def is_given(obj: _T | NotGiven | Omit) -> TypeGuard[_T]:
 # Type safe methods for narrowing types with TypeVars.
 # The default narrowing for isinstance(obj, dict) is dict[unknown, unknown],
 # however this cause Pyright to rightfully report errors. As we know we don't
-# care about the contained types we can safely use `object` in it's place.
+# care about the contained types we can safely use `object` in its place.
 #
 # There are two separate functions defined, `is_*` and `is_*_t` for different use cases.
 # `is_*` is for when you're dealing with an unknown input

src/asktable/resources/datasources/datasources.py

@@ -116,6 +116,7 @@ def create(
             "mogdb",
             "hologres",
             "maxcompute",
+            "dap",
         ],
         access_config: Optional[datasource_create_params.AccessConfig] | Omit = omit,
         name: Optional[str] | Omit = omit,
@@ -224,6 +225,7 @@ def update(
                 "mogdb",
                 "hologres",
                 "maxcompute",
+                "dap",
             ]
         ]
         | Omit = omit,
@@ -614,6 +616,7 @@ async def create(
             "mogdb",
             "hologres",
             "maxcompute",
+            "dap",
         ],
         access_config: Optional[datasource_create_params.AccessConfig] | Omit = omit,
         name: Optional[str] | Omit = omit,
@@ -722,6 +725,7 @@ async def update(
                 "mogdb",
                 "hologres",
                 "maxcompute",
+                "dap",
             ]
         ]
         | Omit = omit,

src/asktable/types/datasource.py

@@ -40,6 +40,7 @@ class Datasource(BaseModel):
         "mogdb",
         "hologres",
         "maxcompute",
+        "dap",
     ]
     """数据源引擎"""
 

src/asktable/types/datasource_create_params.py

@@ -41,6 +41,7 @@ class DatasourceCreateParams(TypedDict, total=False):
             "mogdb",
             "hologres",
             "maxcompute",
+            "dap",
         ]
     ]
     """数据源引擎"""

src/asktable/types/datasource_retrieve_response.py

@@ -95,6 +95,7 @@ class DatasourceRetrieveResponse(BaseModel):
         "mogdb",
         "hologres",
         "maxcompute",
+        "dap",
     ]
     """数据源引擎"""