chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@81532b9

vdp/pipeline/v1beta/pipeline_pb2.pyi

@@ -1290,8 +1290,8 @@ class CloneNamespacePipelineReleaseResponse(google.protobuf.message.Message):
 global___CloneNamespacePipelineReleaseResponse = CloneNamespacePipelineReleaseResponse
 
 @typing_extensions.final
-class SendNamespacePipelineEventRequest(google.protobuf.message.Message):
-    """SendNamespacePipelineEventRequest"""
+class HandleNamespacePipelineWebhookEventRequest(google.protobuf.message.Message):
+    """HandleNamespacePipelineWebhookEventRequest"""
 
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
 
@@ -1323,11 +1323,11 @@ class SendNamespacePipelineEventRequest(google.protobuf.message.Message):
     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
+global___HandleNamespacePipelineWebhookEventRequest = HandleNamespacePipelineWebhookEventRequest
 
 @typing_extensions.final
-class SendNamespacePipelineEventResponse(google.protobuf.message.Message):
-    """SendNamespacePipelineEventResponse"""
+class HandleNamespacePipelineWebhookEventResponse(google.protobuf.message.Message):
+    """HandleNamespacePipelineWebhookEventResponse"""
 
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
 
@@ -1343,11 +1343,11 @@ class SendNamespacePipelineEventResponse(google.protobuf.message.Message):
     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
+global___HandleNamespacePipelineWebhookEventResponse = HandleNamespacePipelineWebhookEventResponse
 
 @typing_extensions.final
-class SendNamespacePipelineReleaseEventRequest(google.protobuf.message.Message):
-    """SendNamespacePipelineReleaseEventRequest"""
+class HandleNamespacePipelineReleaseWebhookEventRequest(google.protobuf.message.Message):
+    """HandleNamespacePipelineReleaseWebhookEventRequest"""
 
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
 
@@ -1383,11 +1383,11 @@ class SendNamespacePipelineReleaseEventRequest(google.protobuf.message.Message):
     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
+global___HandleNamespacePipelineReleaseWebhookEventRequest = HandleNamespacePipelineReleaseWebhookEventRequest
 
 @typing_extensions.final
-class SendNamespacePipelineReleaseEventResponse(google.protobuf.message.Message):
-    """SendNamespacePipelineReleaseEventResponse"""
+class HandleNamespacePipelineReleaseWebhookEventResponse(google.protobuf.message.Message):
+    """HandleNamespacePipelineReleaseWebhookEventResponse"""
 
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
 
@@ -1403,7 +1403,59 @@ class SendNamespacePipelineReleaseEventResponse(google.protobuf.message.Message)
     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
+global___HandleNamespacePipelineReleaseWebhookEventResponse = HandleNamespacePipelineReleaseWebhookEventResponse
+
+@typing_extensions.final
+class DispatchPipelineWebhookEventRequest(google.protobuf.message.Message):
+    """DispatchPipelineWebhookEventRequest represents a request to dispatch webhook events
+    for a pipeline. The request contains the webhook type and event message that
+    will be processed by the event router and dispatched to the appropriate pipeline
+    based on the webhook type and message. The event message contains the payload
+    data that will be used to trigger pipeline execution.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    WEBHOOK_TYPE_FIELD_NUMBER: builtins.int
+    MESSAGE_FIELD_NUMBER: builtins.int
+    webhook_type: builtins.str
+    """Webhook Type"""
+    @property
+    def message(self) -> google.protobuf.struct_pb2.Struct:
+        """Event"""
+    def __init__(
+        self,
+        *,
+        webhook_type: builtins.str = ...,
+        message: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["message", b"message"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["message", b"message", "webhook_type", b"webhook_type"]) -> None: ...
+
+global___DispatchPipelineWebhookEventRequest = DispatchPipelineWebhookEventRequest
+
+@typing_extensions.final
+class DispatchPipelineWebhookEventResponse(google.protobuf.message.Message):
+    """DispatchPipelineWebhookEventResponse represents a response to dispatch webhook events
+    for a pipeline. The response contains the response message that will be sent
+    back to the webhook sender.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    RESPONSE_FIELD_NUMBER: builtins.int
+    @property
+    def response(self) -> google.protobuf.struct_pb2.Struct:
+        """Response"""
+    def __init__(
+        self,
+        *,
+        response: google.protobuf.struct_pb2.Struct | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["response", b"response"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["response", b"response"]) -> None: ...
+
+global___DispatchPipelineWebhookEventResponse = DispatchPipelineWebhookEventResponse
 
 @typing_extensions.final
 class TriggerNamespacePipelineRequest(google.protobuf.message.Message):

vdp/pipeline/v1beta/pipeline_public_service_pb2_grpc.py

@@ -87,15 +87,20 @@ 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.HandleNamespacePipelineWebhookEvent = channel.unary_unary(
+                '/vdp.pipeline.v1beta.PipelinePublicService/HandleNamespacePipelineWebhookEvent',
+                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventRequest.SerializeToString,
+                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventResponse.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.HandleNamespacePipelineReleaseWebhookEvent = channel.unary_unary(
+                '/vdp.pipeline.v1beta.PipelinePublicService/HandleNamespacePipelineReleaseWebhookEvent',
+                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventRequest.SerializeToString,
+                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventResponse.FromString,
+                )
+        self.DispatchPipelineWebhookEvent = channel.unary_unary(
+                '/vdp.pipeline.v1beta.PipelinePublicService/DispatchPipelineWebhookEvent',
+                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventRequest.SerializeToString,
+                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventResponse.FromString,
                 )
         self.TriggerNamespacePipeline = channel.unary_unary(
                 '/vdp.pipeline.v1beta.PipelinePublicService/TriggerNamespacePipeline',
@@ -638,15 +643,27 @@ def CloneNamespacePipeline(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def SendNamespacePipelineEvent(self, request, context):
-        """SendNamespacePipelineEvent
+    def HandleNamespacePipelineWebhookEvent(self, request, context):
+        """HandleNamespacePipelineWebhookEvent
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def SendNamespacePipelineReleaseEvent(self, request, context):
-        """SendNamespacePipelineReleaseEvent
+    def HandleNamespacePipelineReleaseWebhookEvent(self, request, context):
+        """HandleNamespacePipelineReleaseWebhookEvent
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def DispatchPipelineWebhookEvent(self, request, context):
+        """Dispatch Pipeline Webhook Event
+
+        Handles webhook events by routing them to the appropriate pipeline based on the webhook type and message.
+        The webhook type determines which component processes the event, while the message payload contains data
+        that triggers pipeline execution. The pipeline processes the event using configured handlers and returns
+        a response to the webhook sender.
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')
@@ -1662,15 +1679,20 @@ 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,
+            'HandleNamespacePipelineWebhookEvent': grpc.unary_unary_rpc_method_handler(
+                    servicer.HandleNamespacePipelineWebhookEvent,
+                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventRequest.FromString,
+                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventResponse.SerializeToString,
+            ),
+            'HandleNamespacePipelineReleaseWebhookEvent': grpc.unary_unary_rpc_method_handler(
+                    servicer.HandleNamespacePipelineReleaseWebhookEvent,
+                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventRequest.FromString,
+                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventResponse.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,
+            'DispatchPipelineWebhookEvent': grpc.unary_unary_rpc_method_handler(
+                    servicer.DispatchPipelineWebhookEvent,
+                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventRequest.FromString,
+                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventResponse.SerializeToString,
             ),
             'TriggerNamespacePipeline': grpc.unary_unary_rpc_method_handler(
                     servicer.TriggerNamespacePipeline,
@@ -2303,7 +2325,24 @@ def CloneNamespacePipeline(request,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
     @staticmethod
-    def SendNamespacePipelineEvent(request,
+    def HandleNamespacePipelineWebhookEvent(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/HandleNamespacePipelineWebhookEvent',
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventRequest.SerializeToString,
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineWebhookEventResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def HandleNamespacePipelineReleaseWebhookEvent(request,
             target,
             options=(),
             channel_credentials=None,
@@ -2313,14 +2352,14 @@ def SendNamespacePipelineEvent(request,
             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,
+        return grpc.experimental.unary_unary(request, target, '/vdp.pipeline.v1beta.PipelinePublicService/HandleNamespacePipelineReleaseWebhookEvent',
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventRequest.SerializeToString,
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.HandleNamespacePipelineReleaseWebhookEventResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
     @staticmethod
-    def SendNamespacePipelineReleaseEvent(request,
+    def DispatchPipelineWebhookEvent(request,
             target,
             options=(),
             channel_credentials=None,
@@ -2330,9 +2369,9 @@ def SendNamespacePipelineReleaseEvent(request,
             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,
+        return grpc.experimental.unary_unary(request, target, '/vdp.pipeline.v1beta.PipelinePublicService/DispatchPipelineWebhookEvent',
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventRequest.SerializeToString,
+            vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.DispatchPipelineWebhookEventResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)