Skip to content

Update connect-python to v0.10.1 #130

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Gerrit91 merged 3 commits into from
Jun 1, 2026
Merged

Update connect-python to v0.10.1 #130

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e4729e5
Update connect-python to v0.10.1
majst01 Jun 1, 2026
af6cc57
Update to new package name.
Gerrit91 Jun 1, 2026
d937836
Merge branch 'main' into update-connect-python
Gerrit91 Jun 1, 2026
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
6 changes: 3 additions & 3 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,10 @@ require (
github.com/pmezard/go-difflib v1.0.0 // indirect
github.com/stretchr/objx v0.5.3 // indirect
go.yaml.in/yaml/v3 v3.0.4 // indirect
golang.org/x/exp v0.0.0-20260508232706-74f9aab9d74a // indirect
golang.org/x/exp v0.0.0-20260529124908-c761662dc8c9 // indirect
golang.org/x/text v0.37.0 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20260523011958-0a33c5d7ca68 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20260523011958-0a33c5d7ca68 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20260526163538-3dc84a4a5aaa // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa // indirect
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
)
12 changes: 6 additions & 6 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,14 +51,14 @@ github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu
github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc=
go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
golang.org/x/exp v0.0.0-20260508232706-74f9aab9d74a h1:+3jdDGGB8NGb1Zktc737jlt3/A5f6UlwSzmvqUuufxw=
golang.org/x/exp v0.0.0-20260508232706-74f9aab9d74a/go.mod h1:d2fgXJLVs4dYDHUk5lwMIfzRzSrWCfGZb0ZqeLa/Vcw=
golang.org/x/exp v0.0.0-20260529124908-c761662dc8c9 h1:4d4PbuBNwaxMXkXI8yiIYjydtMU+04RHeuSxJdgKftM=
golang.org/x/exp v0.0.0-20260529124908-c761662dc8c9/go.mod h1:d2fgXJLVs4dYDHUk5lwMIfzRzSrWCfGZb0ZqeLa/Vcw=
golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
google.golang.org/genproto/googleapis/api v0.0.0-20260523011958-0a33c5d7ca68 h1:WVVw1Nl19li0fMX++FJ3ye1z9+S1N35QODDy5qpnaXw=
google.golang.org/genproto/googleapis/api v0.0.0-20260523011958-0a33c5d7ca68/go.mod h1:1dCETSCY2YKZNXQE3h4fun3TYwF5p8jejRKZgfWAgAY=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260523011958-0a33c5d7ca68 h1:PvEgGJf9C/1u5CHkInMg7UFYYUoiaQmW2LbtH0pjB78=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260523011958-0a33c5d7ca68/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
google.golang.org/genproto/googleapis/api v0.0.0-20260526163538-3dc84a4a5aaa h1:Kjn0N0tCrDgiAFW+lGO4JZ3ck44CehvJQMAwj9QF0G8=
google.golang.org/genproto/googleapis/api v0.0.0-20260526163538-3dc84a4a5aaa/go.mod h1:q4lMZS6kskjT5HvCPrnnypcDPVJqT/f4nfxmkE7gryY=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa h1:mZHHdPZl0dbGHCflZgAq/Q468DWVFcU2whhB2KAo8fk=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
Expand Down
2 changes: 1 addition & 1 deletion proto/buf.gen.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ plugins:
out: ../python
- remote: buf.build/protocolbuffers/pyi:v35.0
out: ../python
- remote: buf.build/connectrpc/python:v0.8.1
- remote: buf.build/connectrpc/python:v0.10.1
out: ../python
# js
- remote: buf.build/bufbuild/es:v2.12.0
Expand Down
15 changes: 13 additions & 2 deletions python/metalstack/admin/v2/audit_connect.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@

from connectrpc.client import ConnectClient, ConnectClientSync
from connectrpc.code import Code
from connectrpc.codec import Codec
from connectrpc.compression import Compression
from connectrpc.errors import ConnectError
from connectrpc.interceptor import Interceptor, InterceptorSync
from connectrpc.method import IdempotencyLevel, MethodInfo
Expand All @@ -24,7 +26,7 @@ async def list(self, request: metalstack_dot_admin_dot_v2_dot_audit__pb2.AuditSe


class AuditServiceASGIApplication(ConnectASGIApplication[AuditService]):
def __init__(self, service: AuditService | AsyncGenerator[AuditService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: AuditService | AsyncGenerator[AuditService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
service=service,
endpoints=lambda svc: {
Expand All @@ -51,6 +53,8 @@ def __init__(self, service: AuditService | AsyncGenerator[AuditService], *, inte
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -101,6 +105,9 @@ async def list(
)





class AuditServiceSync(Protocol):
def get(self, request: metalstack_dot_admin_dot_v2_dot_audit__pb2.AuditServiceGetRequest, ctx: RequestContext) -> metalstack_dot_admin_dot_v2_dot_audit__pb2.AuditServiceGetResponse:
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
Expand All @@ -109,7 +116,7 @@ def list(self, request: metalstack_dot_admin_dot_v2_dot_audit__pb2.AuditServiceL


class AuditServiceWSGIApplication(ConnectWSGIApplication):
def __init__(self, service: AuditServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: AuditServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
endpoints={
"/metalstack.admin.v2.AuditService/Get": EndpointSync.unary(
Expand All @@ -135,6 +142,8 @@ def __init__(self, service: AuditServiceSync, interceptors: Iterable[Interceptor
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -183,3 +192,5 @@ def list(
headers=headers,
timeout_ms=timeout_ms,
)


15 changes: 13 additions & 2 deletions python/metalstack/admin/v2/component_connect.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@

from connectrpc.client import ConnectClient, ConnectClientSync
from connectrpc.code import Code
from connectrpc.codec import Codec
from connectrpc.compression import Compression
from connectrpc.errors import ConnectError
from connectrpc.interceptor import Interceptor, InterceptorSync
from connectrpc.method import IdempotencyLevel, MethodInfo
Expand All @@ -27,7 +29,7 @@ async def list(self, request: metalstack_dot_admin_dot_v2_dot_component__pb2.Com


class ComponentServiceASGIApplication(ConnectASGIApplication[ComponentService]):
def __init__(self, service: ComponentService | AsyncGenerator[ComponentService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: ComponentService | AsyncGenerator[ComponentService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
service=service,
endpoints=lambda svc: {
Expand Down Expand Up @@ -64,6 +66,8 @@ def __init__(self, service: ComponentService | AsyncGenerator[ComponentService],
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -134,6 +138,9 @@ async def list(
)





class ComponentServiceSync(Protocol):
def get(self, request: metalstack_dot_admin_dot_v2_dot_component__pb2.ComponentServiceGetRequest, ctx: RequestContext) -> metalstack_dot_admin_dot_v2_dot_component__pb2.ComponentServiceGetResponse:
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
Expand All @@ -144,7 +151,7 @@ def list(self, request: metalstack_dot_admin_dot_v2_dot_component__pb2.Component


class ComponentServiceWSGIApplication(ConnectWSGIApplication):
def __init__(self, service: ComponentServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: ComponentServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
endpoints={
"/metalstack.admin.v2.ComponentService/Get": EndpointSync.unary(
Expand Down Expand Up @@ -180,6 +187,8 @@ def __init__(self, service: ComponentServiceSync, interceptors: Iterable[Interce
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -248,3 +257,5 @@ def list(
headers=headers,
timeout_ms=timeout_ms,
)


15 changes: 13 additions & 2 deletions python/metalstack/admin/v2/filesystem_connect.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@

from connectrpc.client import ConnectClient, ConnectClientSync
from connectrpc.code import Code
from connectrpc.codec import Codec
from connectrpc.compression import Compression
from connectrpc.errors import ConnectError
from connectrpc.interceptor import Interceptor, InterceptorSync
from connectrpc.method import IdempotencyLevel, MethodInfo
Expand All @@ -30,7 +32,7 @@ async def match(self, request: metalstack_dot_admin_dot_v2_dot_filesystem__pb2.F


class FilesystemServiceASGIApplication(ConnectASGIApplication[FilesystemService]):
def __init__(self, service: FilesystemService | AsyncGenerator[FilesystemService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: FilesystemService | AsyncGenerator[FilesystemService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
service=service,
endpoints=lambda svc: {
Expand Down Expand Up @@ -77,6 +79,8 @@ def __init__(self, service: FilesystemService | AsyncGenerator[FilesystemService
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -167,6 +171,9 @@ async def match(
)





class FilesystemServiceSync(Protocol):
def create(self, request: metalstack_dot_admin_dot_v2_dot_filesystem__pb2.FilesystemServiceCreateRequest, ctx: RequestContext) -> metalstack_dot_admin_dot_v2_dot_filesystem__pb2.FilesystemServiceCreateResponse:
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
Expand All @@ -179,7 +186,7 @@ def match(self, request: metalstack_dot_admin_dot_v2_dot_filesystem__pb2.Filesys


class FilesystemServiceWSGIApplication(ConnectWSGIApplication):
def __init__(self, service: FilesystemServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: FilesystemServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
endpoints={
"/metalstack.admin.v2.FilesystemService/Create": EndpointSync.unary(
Expand Down Expand Up @@ -225,6 +232,8 @@ def __init__(self, service: FilesystemServiceSync, interceptors: Iterable[Interc
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -313,3 +322,5 @@ def match(
headers=headers,
timeout_ms=timeout_ms,
)


15 changes: 13 additions & 2 deletions python/metalstack/admin/v2/image_connect.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@

from connectrpc.client import ConnectClient, ConnectClientSync
from connectrpc.code import Code
from connectrpc.codec import Codec
from connectrpc.compression import Compression
from connectrpc.errors import ConnectError
from connectrpc.interceptor import Interceptor, InterceptorSync
from connectrpc.method import IdempotencyLevel, MethodInfo
Expand All @@ -30,7 +32,7 @@ async def usage(self, request: metalstack_dot_admin_dot_v2_dot_image__pb2.ImageS


class ImageServiceASGIApplication(ConnectASGIApplication[ImageService]):
def __init__(self, service: ImageService | AsyncGenerator[ImageService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: ImageService | AsyncGenerator[ImageService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
service=service,
endpoints=lambda svc: {
Expand Down Expand Up @@ -77,6 +79,8 @@ def __init__(self, service: ImageService | AsyncGenerator[ImageService], *, inte
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -167,6 +171,9 @@ async def usage(
)





class ImageServiceSync(Protocol):
def create(self, request: metalstack_dot_admin_dot_v2_dot_image__pb2.ImageServiceCreateRequest, ctx: RequestContext) -> metalstack_dot_admin_dot_v2_dot_image__pb2.ImageServiceCreateResponse:
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
Expand All @@ -179,7 +186,7 @@ def usage(self, request: metalstack_dot_admin_dot_v2_dot_image__pb2.ImageService


class ImageServiceWSGIApplication(ConnectWSGIApplication):
def __init__(self, service: ImageServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: ImageServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
endpoints={
"/metalstack.admin.v2.ImageService/Create": EndpointSync.unary(
Expand Down Expand Up @@ -225,6 +232,8 @@ def __init__(self, service: ImageServiceSync, interceptors: Iterable[Interceptor
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -313,3 +322,5 @@ def usage(
headers=headers,
timeout_ms=timeout_ms,
)


15 changes: 13 additions & 2 deletions python/metalstack/admin/v2/ip_connect.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@

from connectrpc.client import ConnectClient, ConnectClientSync
from connectrpc.code import Code
from connectrpc.codec import Codec
from connectrpc.compression import Compression
from connectrpc.errors import ConnectError
from connectrpc.interceptor import Interceptor, InterceptorSync
from connectrpc.method import IdempotencyLevel, MethodInfo
Expand All @@ -21,7 +23,7 @@ async def list(self, request: metalstack_dot_admin_dot_v2_dot_ip__pb2.IPServiceL


class IPServiceASGIApplication(ConnectASGIApplication[IPService]):
def __init__(self, service: IPService | AsyncGenerator[IPService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: IPService | AsyncGenerator[IPService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
service=service,
endpoints=lambda svc: {
Expand All @@ -38,6 +40,8 @@ def __init__(self, service: IPService | AsyncGenerator[IPService], *, intercepto
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -68,13 +72,16 @@ async def list(
)





class IPServiceSync(Protocol):
def list(self, request: metalstack_dot_admin_dot_v2_dot_ip__pb2.IPServiceListRequest, ctx: RequestContext) -> metalstack_dot_admin_dot_v2_dot_ip__pb2.IPServiceListResponse:
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")


class IPServiceWSGIApplication(ConnectWSGIApplication):
def __init__(self, service: IPServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None) -> None:
def __init__(self, service: IPServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
super().__init__(
endpoints={
"/metalstack.admin.v2.IPService/List": EndpointSync.unary(
Expand All @@ -90,6 +97,8 @@ def __init__(self, service: IPServiceSync, interceptors: Iterable[InterceptorSyn
},
interceptors=interceptors,
read_max_bytes=read_max_bytes,
compressions=compressions,
codecs=codecs,
)

@property
Expand Down Expand Up @@ -118,3 +127,5 @@ def list(
headers=headers,
timeout_ms=timeout_ms,
)


Loading
Loading