GRPC clients version 11.8.0

Author: clarifai-prod

clarifai_grpc/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "11.7.9"
+__version__ = "11.8.0"
 
 import os
 

clarifai_grpc/grpc/api/resources_pb2.py

@@ -14477,6 +14477,7 @@ class InstanceType(google.protobuf.message.Message):
     CLOUD_PROVIDER_FIELD_NUMBER: builtins.int
     REGION_FIELD_NUMBER: builtins.int
     ALLOWED_CAPACITY_TYPES_FIELD_NUMBER: builtins.int
+    FEATURE_FLAG_GROUP_FIELD_NUMBER: builtins.int
     id: builtins.str
     description: builtins.str
     """Short description of instance type."""
@@ -14491,6 +14492,8 @@ class InstanceType(google.protobuf.message.Message):
     @property
     def allowed_capacity_types(self) -> global___NodeCapacityType:
         """The capacity types allowed for this instance type. If empty - all capacity types are allowed."""
+    feature_flag_group: builtins.str
+    """The feature flag group associated with this instance type."""
     def __init__(
         self,
         *,
@@ -14501,6 +14504,7 @@ class InstanceType(google.protobuf.message.Message):
         cloud_provider: global___CloudProvider | None = ...,
         region: builtins.str = ...,
         allowed_capacity_types: global___NodeCapacityType | None = ...,
+        feature_flag_group: builtins.str = ...,
     ) -> None: ...
     def HasField(
         self,
@@ -14524,6 +14528,8 @@ class InstanceType(google.protobuf.message.Message):
             b"compute_info",
             "description",
             b"description",
+            "feature_flag_group",
+            b"feature_flag_group",
             "id",
             b"id",
             "price",
@@ -14710,6 +14716,7 @@ class ComputeInfo(google.protobuf.message.Message):
     NUM_ACCELERATORS_FIELD_NUMBER: builtins.int
     ACCELERATOR_MEMORY_FIELD_NUMBER: builtins.int
     ACCELERATOR_TYPE_FIELD_NUMBER: builtins.int
+    ACCELERATOR_TOPOLOGY_FIELD_NUMBER: builtins.int
     cpu_limit: builtins.str
     """Amount of CPUs to use as a limit. This follows kubernetes notation like: "1", "100m", "4.5", etc.
     See https://kubernetes.io/docs/reference/kubernetes-api/common-definitions/quantity/
@@ -14755,6 +14762,19 @@ class ComputeInfo(google.protobuf.message.Message):
         """Or should it be removed completely and use the nodepool accelerator type itself.
         These are the supported accelerators that the model can run on.
         """
+    @property
+    def accelerator_topology(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]:
+        """The number of nodes of this type needed to serve this resource.
+        Since 0 is not valid, this will default to 1 if 0 is provided.
+        uint32 num_nodes = 6; // FUTURE
+
+        For multi-host accelerators (i.e., TPU Slices), this defines the slice topology.
+        Corresponds to the tpu.googleapis.com/topology annotation.
+        Example: "2x2x1" for a 16-chip slice using v4 TPUs.
+        Leave empty for single-host accelerators like GPUs or non-slice TPUs.
+        """
     def __init__(
         self,
         *,
@@ -14765,12 +14785,15 @@ class ComputeInfo(google.protobuf.message.Message):
         num_accelerators: builtins.int = ...,
         accelerator_memory: builtins.str = ...,
         accelerator_type: collections.abc.Iterable[builtins.str] | None = ...,
+        accelerator_topology: collections.abc.Iterable[builtins.str] | None = ...,
     ) -> None: ...
     def ClearField(
         self,
         field_name: typing_extensions.Literal[
             "accelerator_memory",
             b"accelerator_memory",
+            "accelerator_topology",
+            b"accelerator_topology",
             "accelerator_type",
             b"accelerator_type",
             "cpu_limit",
@@ -17485,3 +17508,51 @@ class MetricSearchQuery(google.protobuf.message.Message):
     ) -> None: ...
 
 global___MetricSearchQuery = MetricSearchQuery
+
+@typing_extensions.final
+class MetricTypeLabels(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    @typing_extensions.final
+    class LabelWithValues(google.protobuf.message.Message):
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        LABEL_FIELD_NUMBER: builtins.int
+        VALUES_FIELD_NUMBER: builtins.int
+        label: global___MetricLabel.ValueType
+        @property
+        def values(
+            self,
+        ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]:
+            """sample values for this label"""
+        def __init__(
+            self,
+            *,
+            label: global___MetricLabel.ValueType = ...,
+            values: collections.abc.Iterable[builtins.str] | None = ...,
+        ) -> None: ...
+        def ClearField(
+            self, field_name: typing_extensions.Literal["label", b"label", "values", b"values"]
+        ) -> None: ...
+
+    METRIC_TYPE_FIELD_NUMBER: builtins.int
+    LABELS_FIELD_NUMBER: builtins.int
+    metric_type: global___MetricType.ValueType
+    @property
+    def labels(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
+        global___MetricTypeLabels.LabelWithValues
+    ]: ...
+    def __init__(
+        self,
+        *,
+        metric_type: global___MetricType.ValueType = ...,
+        labels: collections.abc.Iterable[global___MetricTypeLabels.LabelWithValues] | None = ...,
+    ) -> None: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal["labels", b"labels", "metric_type", b"metric_type"],
+    ) -> None: ...
+
+global___MetricTypeLabels = MetricTypeLabels

clarifai_grpc/grpc/api/resources_pb2.pyi

@@ -17959,3 +17959,131 @@ class MultiSecretResponse(google.protobuf.message.Message):
     ) -> None: ...
 
 global___MultiSecretResponse = MultiSecretResponse
+
+@typing_extensions.final
+class PostMetricsQueryRequest(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    USER_APP_ID_FIELD_NUMBER: builtins.int
+    QUERY_FIELD_NUMBER: builtins.int
+    @property
+    def user_app_id(self) -> proto.clarifai.api.resources_pb2.UserAppIDSet: ...
+    @property
+    def query(self) -> proto.clarifai.api.resources_pb2.MetricSearchQuery: ...
+    def __init__(
+        self,
+        *,
+        user_app_id: proto.clarifai.api.resources_pb2.UserAppIDSet | None = ...,
+        query: proto.clarifai.api.resources_pb2.MetricSearchQuery | None = ...,
+    ) -> None: ...
+    def HasField(
+        self,
+        field_name: typing_extensions.Literal["query", b"query", "user_app_id", b"user_app_id"],
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal["query", b"query", "user_app_id", b"user_app_id"],
+    ) -> None: ...
+
+global___PostMetricsQueryRequest = PostMetricsQueryRequest
+
+@typing_extensions.final
+class MetricsQueryResponse(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    STATUS_FIELD_NUMBER: builtins.int
+    DATA_FIELD_NUMBER: builtins.int
+    RESOLUTION_FIELD_NUMBER: builtins.int
+    @property
+    def status(self) -> proto.clarifai.api.status.status_pb2.Status: ...
+    @property
+    def data(self) -> proto.clarifai.api.resources_pb2.MetricData: ...
+    resolution: builtins.str
+    def __init__(
+        self,
+        *,
+        status: proto.clarifai.api.status.status_pb2.Status | None = ...,
+        data: proto.clarifai.api.resources_pb2.MetricData | None = ...,
+        resolution: builtins.str = ...,
+    ) -> None: ...
+    def HasField(
+        self, field_name: typing_extensions.Literal["data", b"data", "status", b"status"]
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "data", b"data", "resolution", b"resolution", "status", b"status"
+        ],
+    ) -> None: ...
+
+global___MetricsQueryResponse = MetricsQueryResponse
+
+@typing_extensions.final
+class ListMetricLabelsRequest(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    USER_APP_ID_FIELD_NUMBER: builtins.int
+    METRIC_TYPES_FIELD_NUMBER: builtins.int
+    @property
+    def user_app_id(self) -> proto.clarifai.api.resources_pb2.UserAppIDSet: ...
+    @property
+    def metric_types(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[
+        proto.clarifai.api.resources_pb2.MetricType.ValueType
+    ]: ...
+    def __init__(
+        self,
+        *,
+        user_app_id: proto.clarifai.api.resources_pb2.UserAppIDSet | None = ...,
+        metric_types: collections.abc.Iterable[
+            proto.clarifai.api.resources_pb2.MetricType.ValueType
+        ]
+        | None = ...,
+    ) -> None: ...
+    def HasField(
+        self, field_name: typing_extensions.Literal["user_app_id", b"user_app_id"]
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "metric_types", b"metric_types", "user_app_id", b"user_app_id"
+        ],
+    ) -> None: ...
+
+global___ListMetricLabelsRequest = ListMetricLabelsRequest
+
+@typing_extensions.final
+class MultiMetricLabelsResponse(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    STATUS_FIELD_NUMBER: builtins.int
+    METRIC_TYPE_LABELS_FIELD_NUMBER: builtins.int
+    @property
+    def status(self) -> proto.clarifai.api.status.status_pb2.Status: ...
+    @property
+    def metric_type_labels(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
+        proto.clarifai.api.resources_pb2.MetricTypeLabels
+    ]: ...
+    def __init__(
+        self,
+        *,
+        status: proto.clarifai.api.status.status_pb2.Status | None = ...,
+        metric_type_labels: collections.abc.Iterable[
+            proto.clarifai.api.resources_pb2.MetricTypeLabels
+        ]
+        | None = ...,
+    ) -> None: ...
+    def HasField(
+        self, field_name: typing_extensions.Literal["status", b"status"]
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "metric_type_labels", b"metric_type_labels", "status", b"status"
+        ],
+    ) -> None: ...
+
+global___MultiMetricLabelsResponse = MultiMetricLabelsResponse

clarifai_grpc/grpc/api/service_pb2.py

@@ -1424,6 +1424,16 @@ def __init__(self, channel):
                 request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.DeleteSecretsRequest.SerializeToString,
                 response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.MultiSecretResponse),
                 )
+        self.PostMetricsQuery = channel.unary_unary(
+                '/clarifai.api.V2/PostMetricsQuery',
+                request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.PostMetricsQueryRequest.SerializeToString,
+                response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.MetricsQueryResponse),
+                )
+        self.ListMetricLabels = channel.unary_unary(
+                '/clarifai.api.V2/ListMetricLabels',
+                request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.ListMetricLabelsRequest.SerializeToString,
+                response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.MultiMetricLabelsResponse),
+                )
 
 
 class V2Servicer(object):
@@ -3501,6 +3511,18 @@ def DeleteSecrets(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def PostMetricsQuery(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 ListMetricLabels(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_V2Servicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -4894,6 +4916,16 @@ def add_V2Servicer_to_server(servicer, server):
                     request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.DeleteSecretsRequest.FromString,
                     response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.MultiSecretResponse.SerializeToString,
             ),
+            'PostMetricsQuery': grpc.unary_unary_rpc_method_handler(
+                    servicer.PostMetricsQuery,
+                    request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.PostMetricsQueryRequest.FromString,
+                    response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.MetricsQueryResponse.SerializeToString,
+            ),
+            'ListMetricLabels': grpc.unary_unary_rpc_method_handler(
+                    servicer.ListMetricLabels,
+                    request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.ListMetricLabelsRequest.FromString,
+                    response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.MultiMetricLabelsResponse.SerializeToString,
+            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'clarifai.api.V2', rpc_method_handlers)
@@ -9647,3 +9679,37 @@ def DeleteSecrets(request,
             proto_dot_clarifai_dot_api_dot_service__pb2.MultiSecretResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def PostMetricsQuery(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, '/clarifai.api.V2/PostMetricsQuery',
+            proto_dot_clarifai_dot_api_dot_service__pb2.PostMetricsQueryRequest.SerializeToString,
+            proto_dot_clarifai_dot_api_dot_service__pb2.MetricsQueryResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def ListMetricLabels(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, '/clarifai.api.V2/ListMetricLabels',
+            proto_dot_clarifai_dot_api_dot_service__pb2.ListMetricLabelsRequest.SerializeToString,
+            proto_dot_clarifai_dot_api_dot_service__pb2.MultiMetricLabelsResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)