chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@d93908a

Author: droplet-bot

model/model/v1alpha/model_pb2.pyi

@@ -0,0 +1,99 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from model.model.v1alpha import model_ray_serve_pb2 as model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2
+
+
+class RayServeAPIServiceStub(object):
+    """Missing associated documentation comment in .proto file."""
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.ListApplications = channel.unary_unary(
+                '/model.model.v1alpha.RayServeAPIService/ListApplications',
+                request_serializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsRequest.SerializeToString,
+                response_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsResponse.FromString,
+                )
+        self.Healthz = channel.unary_unary(
+                '/model.model.v1alpha.RayServeAPIService/Healthz',
+                request_serializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzRequest.SerializeToString,
+                response_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzResponse.FromString,
+                )
+
+
+class RayServeAPIServiceServicer(object):
+    """Missing associated documentation comment in .proto file."""
+
+    def ListApplications(self, request, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def Healthz(self, request, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_RayServeAPIServiceServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'ListApplications': grpc.unary_unary_rpc_method_handler(
+                    servicer.ListApplications,
+                    request_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsRequest.FromString,
+                    response_serializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsResponse.SerializeToString,
+            ),
+            'Healthz': grpc.unary_unary_rpc_method_handler(
+                    servicer.Healthz,
+                    request_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzRequest.FromString,
+                    response_serializer=model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzResponse.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'model.model.v1alpha.RayServeAPIService', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class RayServeAPIService(object):
+    """Missing associated documentation comment in .proto file."""
+
+    @staticmethod
+    def ListApplications(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/model.model.v1alpha.RayServeAPIService/ListApplications',
+            model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsRequest.SerializeToString,
+            model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.ListApplicationsResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def Healthz(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/model.model.v1alpha.RayServeAPIService/Healthz',
+            model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzRequest.SerializeToString,
+            model_dot_model_dot_v1alpha_dot_model__ray__serve__pb2.HealthzResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

model/model/v1alpha/model_ray_serve_pb2.py

@@ -0,0 +1,68 @@
+"""
+@generated by mypy-protobuf.  Do not edit manually!
+isort:skip_file
+Copyright 2017 The Ray Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+"""
+import abc
+import collections.abc
+import grpc
+import grpc.aio
+import model.model.v1alpha.model_ray_serve_pb2
+import typing
+
+_T = typing.TypeVar('_T')
+
+class _MaybeAsyncIterator(collections.abc.AsyncIterator[_T], collections.abc.Iterator[_T], metaclass=abc.ABCMeta):
+    ...
+
+class _ServicerContext(grpc.ServicerContext, grpc.aio.ServicerContext):  # type: ignore
+    ...
+
+class RayServeAPIServiceStub:
+    def __init__(self, channel: typing.Union[grpc.Channel, grpc.aio.Channel]) -> None: ...
+    ListApplications: grpc.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_serve_pb2.ListApplicationsRequest,
+        model.model.v1alpha.model_ray_serve_pb2.ListApplicationsResponse,
+    ]
+    Healthz: grpc.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_serve_pb2.HealthzRequest,
+        model.model.v1alpha.model_ray_serve_pb2.HealthzResponse,
+    ]
+
+class RayServeAPIServiceAsyncStub:
+    ListApplications: grpc.aio.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_serve_pb2.ListApplicationsRequest,
+        model.model.v1alpha.model_ray_serve_pb2.ListApplicationsResponse,
+    ]
+    Healthz: grpc.aio.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_serve_pb2.HealthzRequest,
+        model.model.v1alpha.model_ray_serve_pb2.HealthzResponse,
+    ]
+
+class RayServeAPIServiceServicer(metaclass=abc.ABCMeta):
+    @abc.abstractmethod
+    def ListApplications(
+        self,
+        request: model.model.v1alpha.model_ray_serve_pb2.ListApplicationsRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[model.model.v1alpha.model_ray_serve_pb2.ListApplicationsResponse, collections.abc.Awaitable[model.model.v1alpha.model_ray_serve_pb2.ListApplicationsResponse]]: ...
+    @abc.abstractmethod
+    def Healthz(
+        self,
+        request: model.model.v1alpha.model_ray_serve_pb2.HealthzRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[model.model.v1alpha.model_ray_serve_pb2.HealthzResponse, collections.abc.Awaitable[model.model.v1alpha.model_ray_serve_pb2.HealthzResponse]]: ...
+
+def add_RayServeAPIServiceServicer_to_server(servicer: RayServeAPIServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...

model/model/v1alpha/model_ray_serve_pb2.pyi

@@ -0,0 +1,56 @@
+"""
+@generated by mypy-protobuf.  Do not edit manually!
+isort:skip_file
+"""
+import builtins
+import collections.abc
+import google.protobuf.descriptor
+import google.protobuf.internal.containers
+import google.protobuf.message
+import google.protobuf.struct_pb2
+import sys
+
+if sys.version_info >= (3, 8):
+    import typing as typing_extensions
+else:
+    import typing_extensions
+
+DESCRIPTOR: google.protobuf.descriptor.FileDescriptor
+
+@typing_extensions.final
+class CallRequest(google.protobuf.message.Message):
+    """CallRequest represents a request for model inference"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    TASK_INPUTS_FIELD_NUMBER: builtins.int
+    @property
+    def task_inputs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[google.protobuf.struct_pb2.Struct]:
+        """Inference input parameters."""
+    def __init__(
+        self,
+        *,
+        task_inputs: collections.abc.Iterable[google.protobuf.struct_pb2.Struct] | None = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["task_inputs", b"task_inputs"]) -> None: ...
+
+global___CallRequest = CallRequest
+
+@typing_extensions.final
+class CallResponse(google.protobuf.message.Message):
+    """CallResponse represents a response for model inference"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    TASK_OUTPUTS_FIELD_NUMBER: builtins.int
+    @property
+    def task_outputs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[google.protobuf.struct_pb2.Struct]:
+        """Model inference outputs."""
+    def __init__(
+        self,
+        *,
+        task_outputs: collections.abc.Iterable[google.protobuf.struct_pb2.Struct] | None = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["task_outputs", b"task_outputs"]) -> None: ...
+
+global___CallResponse = CallResponse

model/model/v1alpha/model_ray_serve_pb2_grpc.py

@@ -0,0 +1,72 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from model.model.v1alpha import model_ray_user_defined_pb2 as model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2
+
+
+class RayUserDefinedServiceStub(object):
+    """Ray user defined service for internal process
+    """
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.__call__ = channel.unary_unary(
+                '/model.model.v1alpha.RayUserDefinedService/__call__',
+                request_serializer=model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallRequest.SerializeToString,
+                response_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallResponse.FromString,
+                )
+
+
+class RayUserDefinedServiceServicer(object):
+    """Ray user defined service for internal process
+    """
+
+    def __call__(self, request, context):
+        """Trigger method is the default trigger entry for ray deployment
+        Ray doesn't comply with the naming convention of protobuf, so we need to
+        buf:lint:ignore RPC_PASCAL_CASE
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_RayUserDefinedServiceServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            '__call__': grpc.unary_unary_rpc_method_handler(
+                    servicer.__call__,
+                    request_deserializer=model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallRequest.FromString,
+                    response_serializer=model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallResponse.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'model.model.v1alpha.RayUserDefinedService', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class RayUserDefinedService(object):
+    """Ray user defined service for internal process
+    """
+
+    @staticmethod
+    def __call__(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/model.model.v1alpha.RayUserDefinedService/__call__',
+            model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallRequest.SerializeToString,
+            model_dot_model_dot_v1alpha_dot_model__ray__user__defined__pb2.CallResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

model/model/v1alpha/model_ray_serve_pb2_grpc.pyi

@@ -0,0 +1,59 @@
+"""
+@generated by mypy-protobuf.  Do not edit manually!
+isort:skip_file
+"""
+import abc
+import collections.abc
+import grpc
+import grpc.aio
+import model.model.v1alpha.model_ray_user_defined_pb2
+import typing
+
+_T = typing.TypeVar('_T')
+
+class _MaybeAsyncIterator(collections.abc.AsyncIterator[_T], collections.abc.Iterator[_T], metaclass=abc.ABCMeta):
+    ...
+
+class _ServicerContext(grpc.ServicerContext, grpc.aio.ServicerContext):  # type: ignore
+    ...
+
+class RayUserDefinedServiceStub:
+    """Ray user defined service for internal process"""
+
+    def __init__(self, channel: typing.Union[grpc.Channel, grpc.aio.Channel]) -> None: ...
+    __call__: grpc.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_user_defined_pb2.CallRequest,
+        model.model.v1alpha.model_ray_user_defined_pb2.CallResponse,
+    ]
+    """Trigger method is the default trigger entry for ray deployment
+    Ray doesn't comply with the naming convention of protobuf, so we need to
+    buf:lint:ignore RPC_PASCAL_CASE
+    """
+
+class RayUserDefinedServiceAsyncStub:
+    """Ray user defined service for internal process"""
+
+    __call__: grpc.aio.UnaryUnaryMultiCallable[
+        model.model.v1alpha.model_ray_user_defined_pb2.CallRequest,
+        model.model.v1alpha.model_ray_user_defined_pb2.CallResponse,
+    ]
+    """Trigger method is the default trigger entry for ray deployment
+    Ray doesn't comply with the naming convention of protobuf, so we need to
+    buf:lint:ignore RPC_PASCAL_CASE
+    """
+
+class RayUserDefinedServiceServicer(metaclass=abc.ABCMeta):
+    """Ray user defined service for internal process"""
+
+    @abc.abstractmethod
+    def __call__(
+        self,
+        request: model.model.v1alpha.model_ray_user_defined_pb2.CallRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[model.model.v1alpha.model_ray_user_defined_pb2.CallResponse, collections.abc.Awaitable[model.model.v1alpha.model_ray_user_defined_pb2.CallResponse]]:
+        """Trigger method is the default trigger entry for ray deployment
+        Ray doesn't comply with the naming convention of protobuf, so we need to
+        buf:lint:ignore RPC_PASCAL_CASE
+        """
+
+def add_RayUserDefinedServiceServicer_to_server(servicer: RayUserDefinedServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...