chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@dfbf8fe

vdp/pipeline/v1beta/pipeline_pb2.pyi

@@ -1221,6 +1221,122 @@ class CloneNamespacePipelineReleaseResponse(google.protobuf.message.Message):
 
 global___CloneNamespacePipelineReleaseResponse = CloneNamespacePipelineReleaseResponse
 
+@typing_extensions.final
+class SendNamespacePipelineEventRequest(google.protobuf.message.Message):
+    """SendNamespacePipelineEventRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    NAMESPACE_ID_FIELD_NUMBER: builtins.int
+    PIPELINE_ID_FIELD_NUMBER: builtins.int
+    EVENT_FIELD_NUMBER: builtins.int
+    CODE_FIELD_NUMBER: builtins.int
+    DATA_FIELD_NUMBER: builtins.int
+    namespace_id: builtins.str
+    """Namespace ID"""
+    pipeline_id: builtins.str
+    """Pipeline ID"""
+    event: builtins.str
+    """Event"""
+    code: builtins.str
+    """Code"""
+    @property
+    def data(self) -> google.protobuf.struct_pb2.Struct:
+        """Input data"""
+    def __init__(
+        self,
+        *,
+        namespace_id: builtins.str = ...,
+        pipeline_id: builtins.str = ...,
+        event: builtins.str = ...,
+        code: builtins.str = ...,
+        data: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["data", b"data"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["code", b"code", "data", b"data", "event", b"event", "namespace_id", b"namespace_id", "pipeline_id", b"pipeline_id"]) -> None: ...
+
+global___SendNamespacePipelineEventRequest = SendNamespacePipelineEventRequest
+
+@typing_extensions.final
+class SendNamespacePipelineEventResponse(google.protobuf.message.Message):
+    """SendNamespacePipelineEventResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    DATA_FIELD_NUMBER: builtins.int
+    @property
+    def data(self) -> google.protobuf.struct_pb2.Struct:
+        """data"""
+    def __init__(
+        self,
+        *,
+        data: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["data", b"data"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["data", b"data"]) -> None: ...
+
+global___SendNamespacePipelineEventResponse = SendNamespacePipelineEventResponse
+
+@typing_extensions.final
+class SendNamespacePipelineReleaseEventRequest(google.protobuf.message.Message):
+    """SendNamespacePipelineReleaseEventRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    NAMESPACE_ID_FIELD_NUMBER: builtins.int
+    PIPELINE_ID_FIELD_NUMBER: builtins.int
+    RELEASE_ID_FIELD_NUMBER: builtins.int
+    EVENT_FIELD_NUMBER: builtins.int
+    CODE_FIELD_NUMBER: builtins.int
+    DATA_FIELD_NUMBER: builtins.int
+    namespace_id: builtins.str
+    """Namespace ID"""
+    pipeline_id: builtins.str
+    """Pipeline ID"""
+    release_id: builtins.str
+    """Pipeline ID"""
+    event: builtins.str
+    """Event"""
+    code: builtins.str
+    """Code"""
+    @property
+    def data(self) -> google.protobuf.struct_pb2.Struct:
+        """Input data"""
+    def __init__(
+        self,
+        *,
+        namespace_id: builtins.str = ...,
+        pipeline_id: builtins.str = ...,
+        release_id: builtins.str = ...,
+        event: builtins.str = ...,
+        code: builtins.str = ...,
+        data: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["data", b"data"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["code", b"code", "data", b"data", "event", b"event", "namespace_id", b"namespace_id", "pipeline_id", b"pipeline_id", "release_id", b"release_id"]) -> None: ...
+
+global___SendNamespacePipelineReleaseEventRequest = SendNamespacePipelineReleaseEventRequest
+
+@typing_extensions.final
+class SendNamespacePipelineReleaseEventResponse(google.protobuf.message.Message):
+    """SendNamespacePipelineReleaseEventResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    DATA_FIELD_NUMBER: builtins.int
+    @property
+    def data(self) -> google.protobuf.struct_pb2.Struct:
+        """data"""
+    def __init__(
+        self,
+        *,
+        data: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["data", b"data"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["data", b"data"]) -> None: ...
+
+global___SendNamespacePipelineReleaseEventResponse = SendNamespacePipelineReleaseEventResponse
+
 @typing_extensions.final
 class TriggerNamespacePipelineRequest(google.protobuf.message.Message):
     """TriggerNamespacePipelineRequest represents a request to trigger a user-owned

vdp/pipeline/v1beta/pipeline_public_service_pb2_grpc.py

@@ -86,6 +86,16 @@ def __init__(self, channel):
                 request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.CloneNamespacePipelineRequest.SerializeToString,
                 response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.CloneNamespacePipelineResponse.FromString,
                 )
+        self.SendNamespacePipelineEvent = channel.unary_unary(
+                '/vdp.pipeline.v1beta.PipelinePublicService/SendNamespacePipelineEvent',
+                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventRequest.SerializeToString,
+                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventResponse.FromString,
+                )
+        self.SendNamespacePipelineReleaseEvent = channel.unary_unary(
+                '/vdp.pipeline.v1beta.PipelinePublicService/SendNamespacePipelineReleaseEvent',
+                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventRequest.SerializeToString,
+                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventResponse.FromString,
+                )
         self.TriggerNamespacePipeline = channel.unary_unary(
                 '/vdp.pipeline.v1beta.PipelinePublicService/TriggerNamespacePipeline',
                 request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.TriggerNamespacePipelineRequest.SerializeToString,
@@ -607,6 +617,20 @@ def CloneNamespacePipeline(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def SendNamespacePipelineEvent(self, request, context):
+        """SendNamespacePipelineEvent
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def SendNamespacePipelineReleaseEvent(self, request, context):
+        """SendNamespacePipelineReleaseEvent
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def TriggerNamespacePipeline(self, request, context):
         """Trigger a pipeline
 
@@ -1573,6 +1597,16 @@ def add_PipelinePublicServiceServicer_to_server(servicer, server):
                     request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.CloneNamespacePipelineRequest.FromString,
                     response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.CloneNamespacePipelineResponse.SerializeToString,
             ),
+            'SendNamespacePipelineEvent': grpc.unary_unary_rpc_method_handler(
+                    servicer.SendNamespacePipelineEvent,
+                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventRequest.FromString,
+                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventResponse.SerializeToString,
+            ),
+            'SendNamespacePipelineReleaseEvent': grpc.unary_unary_rpc_method_handler(
+                    servicer.SendNamespacePipelineReleaseEvent,
+                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventRequest.FromString,
+                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventResponse.SerializeToString,
+            ),
             'TriggerNamespacePipeline': grpc.unary_unary_rpc_method_handler(
                     servicer.TriggerNamespacePipeline,
                     request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.TriggerNamespacePipelineRequest.FromString,
@@ -2183,6 +2217,40 @@ def CloneNamespacePipeline(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
+    @staticmethod
+    def SendNamespacePipelineEvent(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, '/vdp.pipeline.v1beta.PipelinePublicService/SendNamespacePipelineEvent',
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventRequest.SerializeToString,
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineEventResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def SendNamespacePipelineReleaseEvent(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, '/vdp.pipeline.v1beta.PipelinePublicService/SendNamespacePipelineReleaseEvent',
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventRequest.SerializeToString,
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.SendNamespacePipelineReleaseEventResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
     @staticmethod
     def TriggerNamespacePipeline(request,
             target,

vdp/pipeline/v1beta/pipeline_public_service_pb2_grpc.pyi

@@ -152,6 +152,16 @@ class PipelinePublicServiceStub:
     Clones a pipeline owned by a namespace. The new pipeline may have a different
     parent, and this can be either a namespace or an organization.
     """
+    SendNamespacePipelineEvent: grpc.UnaryUnaryMultiCallable[
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventRequest,
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventResponse,
+    ]
+    """SendNamespacePipelineEvent"""
+    SendNamespacePipelineReleaseEvent: grpc.UnaryUnaryMultiCallable[
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventRequest,
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventResponse,
+    ]
+    """SendNamespacePipelineReleaseEvent"""
     TriggerNamespacePipeline: grpc.UnaryUnaryMultiCallable[
         vdp.pipeline.v1beta.pipeline_pb2.TriggerNamespacePipelineRequest,
         vdp.pipeline.v1beta.pipeline_pb2.TriggerNamespacePipelineResponse,
@@ -1107,6 +1117,16 @@ class PipelinePublicServiceAsyncStub:
     Clones a pipeline owned by a namespace. The new pipeline may have a different
     parent, and this can be either a namespace or an organization.
     """
+    SendNamespacePipelineEvent: grpc.aio.UnaryUnaryMultiCallable[
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventRequest,
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventResponse,
+    ]
+    """SendNamespacePipelineEvent"""
+    SendNamespacePipelineReleaseEvent: grpc.aio.UnaryUnaryMultiCallable[
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventRequest,
+        vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventResponse,
+    ]
+    """SendNamespacePipelineReleaseEvent"""
     TriggerNamespacePipeline: grpc.aio.UnaryUnaryMultiCallable[
         vdp.pipeline.v1beta.pipeline_pb2.TriggerNamespacePipelineRequest,
         vdp.pipeline.v1beta.pipeline_pb2.TriggerNamespacePipelineResponse,
@@ -2089,6 +2109,20 @@ class PipelinePublicServiceServicer(metaclass=abc.ABCMeta):
         parent, and this can be either a namespace or an organization.
         """
     @abc.abstractmethod
+    def SendNamespacePipelineEvent(
+        self,
+        request: vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventResponse, collections.abc.Awaitable[vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineEventResponse]]:
+        """SendNamespacePipelineEvent"""
+    @abc.abstractmethod
+    def SendNamespacePipelineReleaseEvent(
+        self,
+        request: vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventResponse, collections.abc.Awaitable[vdp.pipeline.v1beta.pipeline_pb2.SendNamespacePipelineReleaseEventResponse]]:
+        """SendNamespacePipelineReleaseEvent"""
+    @abc.abstractmethod
     def TriggerNamespacePipeline(
         self,
         request: vdp.pipeline.v1beta.pipeline_pb2.TriggerNamespacePipelineRequest,