chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@05f4a3b

Author: droplet-bot

vdp/pipeline/v1beta/connector_pb2.py

@@ -18,7 +18,6 @@ import sys
 import typing
 import vdp.pipeline.v1beta.common_pb2
 import vdp.pipeline.v1beta.component_definition_pb2
-import vdp.pipeline.v1beta.connector_pb2
 
 if sys.version_info >= (3, 10):
     import typing as typing_extensions
@@ -291,8 +290,6 @@ class ConnectorComponent(google.protobuf.message.Message):
 
     DEFINITION_NAME_FIELD_NUMBER: builtins.int
     DEFINITION_FIELD_NUMBER: builtins.int
-    CONNECTOR_NAME_FIELD_NUMBER: builtins.int
-    CONNECTOR_FIELD_NUMBER: builtins.int
     TASK_FIELD_NUMBER: builtins.int
     INPUT_FIELD_NUMBER: builtins.int
     CONDITION_FIELD_NUMBER: builtins.int
@@ -301,11 +298,6 @@ class ConnectorComponent(google.protobuf.message.Message):
     @property
     def definition(self) -> vdp.pipeline.v1beta.component_definition_pb2.ConnectorDefinition:
         """Connector definition."""
-    connector_name: builtins.str
-    """Connector name. Leave empty if not created."""
-    @property
-    def connector(self) -> vdp.pipeline.v1beta.connector_pb2.Connector:
-        """Describes the connector details (e.g., configuration to connect with the vendor service)."""
     task: builtins.str
     """Task."""
     @property
@@ -318,14 +310,12 @@ class ConnectorComponent(google.protobuf.message.Message):
         *,
         definition_name: builtins.str = ...,
         definition: vdp.pipeline.v1beta.component_definition_pb2.ConnectorDefinition | None = ...,
-        connector_name: builtins.str = ...,
-        connector: vdp.pipeline.v1beta.connector_pb2.Connector | None = ...,
         task: builtins.str = ...,
         input: google.protobuf.struct_pb2.Struct | None = ...,
         condition: builtins.str = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["connector", b"connector", "definition", b"definition", "input", b"input"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["condition", b"condition", "connector", b"connector", "connector_name", b"connector_name", "definition", b"definition", "definition_name", b"definition_name", "input", b"input", "task", b"task"]) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["definition", b"definition", "input", b"input"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["condition", b"condition", "definition", b"definition", "definition_name", b"definition_name", "input", b"input", "task", b"task"]) -> None: ...
 
 global___ConnectorComponent = ConnectorComponent
 

vdp/pipeline/v1beta/connector_pb2.pyi

@@ -2,7 +2,6 @@
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
 
-from vdp.pipeline.v1beta import connector_pb2 as vdp_dot_pipeline_dot_v1beta_dot_connector__pb2
 from vdp.pipeline.v1beta import pipeline_pb2 as vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2
 
 
@@ -32,21 +31,6 @@ def __init__(self, channel):
                 request_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.ListPipelineReleasesAdminRequest.SerializeToString,
                 response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.ListPipelineReleasesAdminResponse.FromString,
                 )
-        self.ListConnectorsAdmin = channel.unary_unary(
-                '/vdp.pipeline.v1beta.PipelinePrivateService/ListConnectorsAdmin',
-                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminRequest.SerializeToString,
-                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminResponse.FromString,
-                )
-        self.LookUpConnectorAdmin = channel.unary_unary(
-                '/vdp.pipeline.v1beta.PipelinePrivateService/LookUpConnectorAdmin',
-                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminRequest.SerializeToString,
-                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminResponse.FromString,
-                )
-        self.CheckConnector = channel.unary_unary(
-                '/vdp.pipeline.v1beta.PipelinePrivateService/CheckConnector',
-                request_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorRequest.SerializeToString,
-                response_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorResponse.FromString,
-                )
 
 
 class PipelinePrivateServiceServicer(object):
@@ -84,35 +68,6 @@ def ListPipelineReleasesAdmin(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def ListConnectorsAdmin(self, request, context):
-        """List connectors (admin only)
-
-        This is a *private* method that allows admin users to list *all* connectors.
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
-    def LookUpConnectorAdmin(self, request, context):
-        """Get a connector by UID (admin only)
-
-        This is a *private* method that allows admin users to access a connector
-        by its UID.
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
-    def CheckConnector(self, request, context):
-        """Get a connector current state (admin only)
-
-        This is a *private* method that allows admin users to access the state of
-        a connector by its UID.
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
 
 def add_PipelinePrivateServiceServicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -131,21 +86,6 @@ def add_PipelinePrivateServiceServicer_to_server(servicer, server):
                     request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.ListPipelineReleasesAdminRequest.FromString,
                     response_serializer=vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.ListPipelineReleasesAdminResponse.SerializeToString,
             ),
-            'ListConnectorsAdmin': grpc.unary_unary_rpc_method_handler(
-                    servicer.ListConnectorsAdmin,
-                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminRequest.FromString,
-                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminResponse.SerializeToString,
-            ),
-            'LookUpConnectorAdmin': grpc.unary_unary_rpc_method_handler(
-                    servicer.LookUpConnectorAdmin,
-                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminRequest.FromString,
-                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminResponse.SerializeToString,
-            ),
-            'CheckConnector': grpc.unary_unary_rpc_method_handler(
-                    servicer.CheckConnector,
-                    request_deserializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorRequest.FromString,
-                    response_serializer=vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorResponse.SerializeToString,
-            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'vdp.pipeline.v1beta.PipelinePrivateService', rpc_method_handlers)
@@ -208,54 +148,3 @@ def ListPipelineReleasesAdmin(request,
             vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2.ListPipelineReleasesAdminResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
-    @staticmethod
-    def ListConnectorsAdmin(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.PipelinePrivateService/ListConnectorsAdmin',
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminRequest.SerializeToString,
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.ListConnectorsAdminResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
-    @staticmethod
-    def LookUpConnectorAdmin(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.PipelinePrivateService/LookUpConnectorAdmin',
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminRequest.SerializeToString,
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.LookUpConnectorAdminResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
-    @staticmethod
-    def CheckConnector(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.PipelinePrivateService/CheckConnector',
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorRequest.SerializeToString,
-            vdp_dot_pipeline_dot_v1beta_dot_connector__pb2.CheckConnectorResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)