Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .release-please-manifest.json
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
{
".": "0.20.0"
".": "0.21.0"
}
8 changes: 4 additions & 4 deletions .stats.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
configured_endpoints: 66
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-2af1b468584cb44aa9babbbfb82bff4055614fbb5c815084a6b7dacc1cf1a822.yml
openapi_spec_hash: 891affa2849341ea01d62011125f7edc
config_hash: 9421eb86b7f3f4b274f123279da3858e
configured_endpoints: 74
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-3db06d1628149b5ea8303f1c72250664dfd7cb4a14ceb6102f1ae6e85c92c038.yml
openapi_spec_hash: e5b3da2da328eb26d2a70e2521744c62
config_hash: a4124701ae0a474e580d7416adbcfb00
20 changes: 20 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,25 @@
# Changelog

## 0.21.0 (2025-12-02)

Full Changelog: [v0.20.0...v0.21.0](https://github.com/onkernel/kernel-python-sdk/compare/v0.20.0...v0.21.0)

### Features

* Browser pools sdk release ([c2d7408](https://github.com/onkernel/kernel-python-sdk/commit/c2d7408a770ddd34902986015da0bfde3477f586))
* Mason/agent auth api ([b872928](https://github.com/onkernel/kernel-python-sdk/commit/b8729284ba804461749dad0ac4613aea3c6b3ce6))


### Bug Fixes

* ensure streams are always closed ([c82f496](https://github.com/onkernel/kernel-python-sdk/commit/c82f496ba0112b195f65da9498fb22ab65d501fb))


### Chores

* add Python 3.14 classifier and testing ([9a1e7bf](https://github.com/onkernel/kernel-python-sdk/commit/9a1e7bf9c92d64da4a151dd44cc60057c75c63bf))
* **deps:** mypy 1.18.1 has a regression, pin to 1.17 ([038b10d](https://github.com/onkernel/kernel-python-sdk/commit/038b10d52935961c37ebb0806e9b0754b4d53a20))

## 0.20.0 (2025-11-19)

Full Changelog: [v0.19.2...v0.20.0](https://github.com/onkernel/kernel-python-sdk/compare/v0.19.2...v0.20.0)
Expand Down
39 changes: 38 additions & 1 deletion api.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,17 @@
# Shared Types

```python
from kernel.types import AppAction, ErrorDetail, ErrorEvent, ErrorModel, HeartbeatEvent, LogEvent
from kernel.types import (
AppAction,
BrowserExtension,
BrowserProfile,
BrowserViewport,
ErrorDetail,
ErrorEvent,
ErrorModel,
HeartbeatEvent,
LogEvent,
)
```

# Deployments
Expand Down Expand Up @@ -243,3 +253,30 @@ Methods:
- <code title="get /extensions/{id_or_name}">client.extensions.<a href="./src/kernel/resources/extensions.py">download</a>(id_or_name) -> BinaryAPIResponse</code>
- <code title="get /extensions/from_chrome_store">client.extensions.<a href="./src/kernel/resources/extensions.py">download_from_chrome_store</a>(\*\*<a href="src/kernel/types/extension_download_from_chrome_store_params.py">params</a>) -> BinaryAPIResponse</code>
- <code title="post /extensions">client.extensions.<a href="./src/kernel/resources/extensions.py">upload</a>(\*\*<a href="src/kernel/types/extension_upload_params.py">params</a>) -> <a href="./src/kernel/types/extension_upload_response.py">ExtensionUploadResponse</a></code>

# BrowserPools

Types:

```python
from kernel.types import (
BrowserPool,
BrowserPoolAcquireRequest,
BrowserPoolReleaseRequest,
BrowserPoolRequest,
BrowserPoolUpdateRequest,
BrowserPoolListResponse,
BrowserPoolAcquireResponse,
)
```

Methods:

- <code title="post /browser_pools">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">create</a>(\*\*<a href="src/kernel/types/browser_pool_create_params.py">params</a>) -> <a href="./src/kernel/types/browser_pool.py">BrowserPool</a></code>
- <code title="get /browser_pools/{id_or_name}">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">retrieve</a>(id_or_name) -> <a href="./src/kernel/types/browser_pool.py">BrowserPool</a></code>
- <code title="patch /browser_pools/{id_or_name}">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">update</a>(id_or_name, \*\*<a href="src/kernel/types/browser_pool_update_params.py">params</a>) -> <a href="./src/kernel/types/browser_pool.py">BrowserPool</a></code>
- <code title="get /browser_pools">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">list</a>() -> <a href="./src/kernel/types/browser_pool_list_response.py">BrowserPoolListResponse</a></code>
- <code title="delete /browser_pools/{id_or_name}">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">delete</a>(id_or_name, \*\*<a href="src/kernel/types/browser_pool_delete_params.py">params</a>) -> None</code>
- <code title="post /browser_pools/{id_or_name}/acquire">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">acquire</a>(id_or_name, \*\*<a href="src/kernel/types/browser_pool_acquire_params.py">params</a>) -> <a href="./src/kernel/types/browser_pool_acquire_response.py">BrowserPoolAcquireResponse</a></code>
- <code title="post /browser_pools/{id_or_name}/flush">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">flush</a>(id_or_name) -> None</code>
- <code title="post /browser_pools/{id_or_name}/release">client.browser_pools.<a href="./src/kernel/resources/browser_pools.py">release</a>(id_or_name, \*\*<a href="src/kernel/types/browser_pool_release_params.py">params</a>) -> None</code>
5 changes: 3 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[project]
name = "kernel"
version = "0.20.0"
version = "0.21.0"
description = "The official Python library for the kernel API"
dynamic = ["readme"]
license = "Apache-2.0"
Expand All @@ -24,6 +24,7 @@ classifiers = [
"Programming Language :: Python :: 3.11",
"Programming Language :: Python :: 3.12",
"Programming Language :: Python :: 3.13",
"Programming Language :: Python :: 3.14",
"Operating System :: OS Independent",
"Operating System :: POSIX",
"Operating System :: MacOS",
Expand All @@ -45,7 +46,7 @@ managed = true
# version pins are in requirements-dev.lock
dev-dependencies = [
"pyright==1.1.399",
"mypy",
"mypy==1.17",
"respx",
"pytest",
"pytest-asyncio",
Expand Down
4 changes: 3 additions & 1 deletion requirements-dev.lock
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ mdurl==0.1.2
multidict==6.4.4
# via aiohttp
# via yarl
mypy==1.14.1
mypy==1.17.0
mypy-extensions==1.0.0
# via mypy
nodeenv==1.8.0
Expand All @@ -81,6 +81,8 @@ nox==2023.4.22
packaging==23.2
# via nox
# via pytest
pathspec==0.12.1
# via mypy
platformdirs==3.11.0
# via virtualenv
pluggy==1.5.0
Expand Down
8 changes: 4 additions & 4 deletions requirements.lock
Original file line number Diff line number Diff line change
Expand Up @@ -55,21 +55,21 @@ multidict==6.4.4
propcache==0.3.1
# via aiohttp
# via yarl
pydantic==2.11.9
pydantic==2.12.5
# via kernel
pydantic-core==2.33.2
pydantic-core==2.41.5
# via pydantic
sniffio==1.3.0
# via anyio
# via kernel
typing-extensions==4.12.2
typing-extensions==4.15.0
# via anyio
# via kernel
# via multidict
# via pydantic
# via pydantic-core
# via typing-inspection
typing-inspection==0.4.1
typing-inspection==0.4.2
# via pydantic
yarl==1.20.0
# via aiohttp
10 changes: 9 additions & 1 deletion src/kernel/_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
)
from ._utils import is_given, get_async_library
from ._version import __version__
from .resources import apps, proxies, profiles, extensions, deployments, invocations
from .resources import apps, proxies, profiles, extensions, deployments, invocations, browser_pools
from ._streaming import Stream as Stream, AsyncStream as AsyncStream
from ._exceptions import KernelError, APIStatusError
from ._base_client import (
Expand Down Expand Up @@ -57,6 +57,7 @@ class Kernel(SyncAPIClient):
profiles: profiles.ProfilesResource
proxies: proxies.ProxiesResource
extensions: extensions.ExtensionsResource
browser_pools: browser_pools.BrowserPoolsResource
with_raw_response: KernelWithRawResponse
with_streaming_response: KernelWithStreamedResponse

Expand Down Expand Up @@ -145,6 +146,7 @@ def __init__(
self.profiles = profiles.ProfilesResource(self)
self.proxies = proxies.ProxiesResource(self)
self.extensions = extensions.ExtensionsResource(self)
self.browser_pools = browser_pools.BrowserPoolsResource(self)
self.with_raw_response = KernelWithRawResponse(self)
self.with_streaming_response = KernelWithStreamedResponse(self)

Expand Down Expand Up @@ -263,6 +265,7 @@ class AsyncKernel(AsyncAPIClient):
profiles: profiles.AsyncProfilesResource
proxies: proxies.AsyncProxiesResource
extensions: extensions.AsyncExtensionsResource
browser_pools: browser_pools.AsyncBrowserPoolsResource
with_raw_response: AsyncKernelWithRawResponse
with_streaming_response: AsyncKernelWithStreamedResponse

Expand Down Expand Up @@ -351,6 +354,7 @@ def __init__(
self.profiles = profiles.AsyncProfilesResource(self)
self.proxies = proxies.AsyncProxiesResource(self)
self.extensions = extensions.AsyncExtensionsResource(self)
self.browser_pools = browser_pools.AsyncBrowserPoolsResource(self)
self.with_raw_response = AsyncKernelWithRawResponse(self)
self.with_streaming_response = AsyncKernelWithStreamedResponse(self)

Expand Down Expand Up @@ -470,6 +474,7 @@ def __init__(self, client: Kernel) -> None:
self.profiles = profiles.ProfilesResourceWithRawResponse(client.profiles)
self.proxies = proxies.ProxiesResourceWithRawResponse(client.proxies)
self.extensions = extensions.ExtensionsResourceWithRawResponse(client.extensions)
self.browser_pools = browser_pools.BrowserPoolsResourceWithRawResponse(client.browser_pools)


class AsyncKernelWithRawResponse:
Expand All @@ -481,6 +486,7 @@ def __init__(self, client: AsyncKernel) -> None:
self.profiles = profiles.AsyncProfilesResourceWithRawResponse(client.profiles)
self.proxies = proxies.AsyncProxiesResourceWithRawResponse(client.proxies)
self.extensions = extensions.AsyncExtensionsResourceWithRawResponse(client.extensions)
self.browser_pools = browser_pools.AsyncBrowserPoolsResourceWithRawResponse(client.browser_pools)


class KernelWithStreamedResponse:
Expand All @@ -492,6 +498,7 @@ def __init__(self, client: Kernel) -> None:
self.profiles = profiles.ProfilesResourceWithStreamingResponse(client.profiles)
self.proxies = proxies.ProxiesResourceWithStreamingResponse(client.proxies)
self.extensions = extensions.ExtensionsResourceWithStreamingResponse(client.extensions)
self.browser_pools = browser_pools.BrowserPoolsResourceWithStreamingResponse(client.browser_pools)


class AsyncKernelWithStreamedResponse:
Expand All @@ -503,6 +510,7 @@ def __init__(self, client: AsyncKernel) -> None:
self.profiles = profiles.AsyncProfilesResourceWithStreamingResponse(client.profiles)
self.proxies = proxies.AsyncProxiesResourceWithStreamingResponse(client.proxies)
self.extensions = extensions.AsyncExtensionsResourceWithStreamingResponse(client.extensions)
self.browser_pools = browser_pools.AsyncBrowserPoolsResourceWithStreamingResponse(client.browser_pools)


Client = Kernel
Expand Down
22 changes: 12 additions & 10 deletions src/kernel/_streaming.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,11 +54,12 @@ def __stream__(self) -> Iterator[_T]:
process_data = self._client._process_response_data
iterator = self._iter_events()

for sse in iterator:
yield process_data(data=sse.json(), cast_to=cast_to, response=response)

# As we might not fully consume the response stream, we need to close it explicitly
response.close()
try:
for sse in iterator:
yield process_data(data=sse.json(), cast_to=cast_to, response=response)
finally:
# Ensure the response is closed even if the consumer doesn't read all data
response.close()

def __enter__(self) -> Self:
return self
Expand Down Expand Up @@ -117,11 +118,12 @@ async def __stream__(self) -> AsyncIterator[_T]:
process_data = self._client._process_response_data
iterator = self._iter_events()

async for sse in iterator:
yield process_data(data=sse.json(), cast_to=cast_to, response=response)

# As we might not fully consume the response stream, we need to close it explicitly
await response.aclose()
try:
async for sse in iterator:
yield process_data(data=sse.json(), cast_to=cast_to, response=response)
finally:
# Ensure the response is closed even if the consumer doesn't read all data
await response.aclose()

async def __aenter__(self) -> Self:
return self
Expand Down
2 changes: 1 addition & 1 deletion src/kernel/_version.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.

__title__ = "kernel"
__version__ = "0.20.0" # x-release-please-version
__version__ = "0.21.0" # x-release-please-version
14 changes: 14 additions & 0 deletions src/kernel/resources/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,14 @@
InvocationsResourceWithStreamingResponse,
AsyncInvocationsResourceWithStreamingResponse,
)
from .browser_pools import (
BrowserPoolsResource,
AsyncBrowserPoolsResource,
BrowserPoolsResourceWithRawResponse,
AsyncBrowserPoolsResourceWithRawResponse,
BrowserPoolsResourceWithStreamingResponse,
AsyncBrowserPoolsResourceWithStreamingResponse,
)

__all__ = [
"DeploymentsResource",
Expand Down Expand Up @@ -100,4 +108,10 @@
"AsyncExtensionsResourceWithRawResponse",
"ExtensionsResourceWithStreamingResponse",
"AsyncExtensionsResourceWithStreamingResponse",
"BrowserPoolsResource",
"AsyncBrowserPoolsResource",
"BrowserPoolsResourceWithRawResponse",
"AsyncBrowserPoolsResourceWithRawResponse",
"BrowserPoolsResourceWithStreamingResponse",
"AsyncBrowserPoolsResourceWithStreamingResponse",
]
Loading