GRPC clients version 11.11.7

Author: clarifai-prod

clarifai_grpc/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "11.11.2"
+__version__ = "11.11.7"
 
 import os
 

clarifai_grpc/grpc/api/resources_pb2.py

@@ -1371,11 +1371,13 @@ class AppResourceCounts(google.protobuf.message.Message):
     WORKFLOWS_FIELD_NUMBER: builtins.int
     MODULES_FIELD_NUMBER: builtins.int
     INPUTS_FIELD_NUMBER: builtins.int
+    PIPELINES_FIELD_NUMBER: builtins.int
     datasets: builtins.int
     models: builtins.int
     workflows: builtins.int
     modules: builtins.int
     inputs: builtins.int
+    pipelines: builtins.int
     def __init__(
         self,
         *,
@@ -1384,6 +1386,7 @@ class AppResourceCounts(google.protobuf.message.Message):
         workflows: builtins.int = ...,
         modules: builtins.int = ...,
         inputs: builtins.int = ...,
+        pipelines: builtins.int = ...,
     ) -> None: ...
     def ClearField(
         self,
@@ -1396,6 +1399,8 @@ class AppResourceCounts(google.protobuf.message.Message):
             b"models",
             "modules",
             b"modules",
+            "pipelines",
+            b"pipelines",
             "workflows",
             b"workflows",
         ],
@@ -10839,6 +10844,8 @@ class TaskInputSource(google.protobuf.message.Message):
         """Use the inputs from a saved search."""
         DATASET: TaskInputSource._TaskInputSourceType.ValueType  # 3
         """Inputs from a dataset."""
+        INPUT: TaskInputSource._TaskInputSourceType.ValueType  # 4
+        """Single input (e.g. video livestream input)"""
 
     class TaskInputSourceType(
         _TaskInputSourceType, metaclass=_TaskInputSourceTypeEnumTypeWrapper
@@ -10850,6 +10857,8 @@ class TaskInputSource(google.protobuf.message.Message):
     """Use the inputs from a saved search."""
     DATASET: TaskInputSource.TaskInputSourceType.ValueType  # 3
     """Inputs from a dataset."""
+    INPUT: TaskInputSource.TaskInputSourceType.ValueType  # 4
+    """Single input (e.g. video livestream input)"""
 
     TYPE_FIELD_NUMBER: builtins.int
     ID_FIELD_NUMBER: builtins.int
@@ -10991,7 +11000,9 @@ class TaskReviewManualStrategyInfo(google.protobuf.message.Message):
     SAMPLE_PERCENTAGE_FIELD_NUMBER: builtins.int
     APPROVAL_THRESHOLD_FIELD_NUMBER: builtins.int
     sample_percentage: builtins.float
-    """This field represents the percentage of inputs that will be reviewed by reviewers. It is a value between 0 and 1."""
+    """This field represents the percentage of inputs that will be reviewed by reviewers. It is a value between 0 and 1.
+    Deprecated: Not used.
+    """
     approval_threshold: builtins.int
     """Deprecated: Use consensus_strategy_info.approval_threshold_reviewers."""
     def __init__(

clarifai_grpc/grpc/api/resources_pb2.pyi

@@ -466,7 +466,7 @@ class StreamTrackAnnotationsSearchesRequest(google.protobuf.message.Message):
 
     USER_APP_ID_FIELD_NUMBER: builtins.int
     INPUT_ID_FIELD_NUMBER: builtins.int
-    TRACK_ID_FIELD_NUMBER: builtins.int
+    TRACK_IDS_FIELD_NUMBER: builtins.int
     FRAME_NUMBER_START_FIELD_NUMBER: builtins.int
     FRAME_TIME_START_FIELD_NUMBER: builtins.int
     ANNOTATION_TYPE_FIELD_NUMBER: builtins.int
@@ -477,16 +477,26 @@ class StreamTrackAnnotationsSearchesRequest(google.protobuf.message.Message):
     def user_app_id(self) -> proto.clarifai.api.resources_pb2.UserAppIDSet: ...
     input_id: builtins.str
     """The input ID containing the video track annotations to stream"""
-    track_id: builtins.str
-    """Filter annotations by track_id"""
+    @property
+    def track_ids(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]:
+        """Filter annotations by track_ids"""
     frame_number_start: builtins.int
     """Filter annotations starting from this frame number (inclusive)"""
     frame_time_start: builtins.int
     """Filter annotations starting from this time in milliseconds (inclusive)"""
     annotation_type: proto.clarifai.api.resources_pb2.AnnotationDataType.ValueType
     """Filter by annotation type (e.g., "bounding_box", "point", "mask")"""
     max_frames: builtins.int
+    """Maximum number of frames to return. Returns annotations from frames in range [frame_number_start, frame_number_start + max_frames - 1] (inclusive on both ends).
+    For example: frame_number_start=5, max_frames=3 returns frames 5, 6, and 7.
+    Default and max: 10800 frames (3 minutes at 60 FPS)
+    """
     max_duration: builtins.int
+    """Maximum duration in milliseconds to return. Returns annotations from time range [frame_time_start, frame_time_start + max_duration - 1] (inclusive on both ends).
+    Default and max: 180000 ms (3 minutes)
+    """
     @property
     def worker(self) -> proto.clarifai.api.resources_pb2.Worker:
         """Filtering by model version ID within a worker (optional).
@@ -498,7 +508,7 @@ class StreamTrackAnnotationsSearchesRequest(google.protobuf.message.Message):
         *,
         user_app_id: proto.clarifai.api.resources_pb2.UserAppIDSet | None = ...,
         input_id: builtins.str = ...,
-        track_id: builtins.str = ...,
+        track_ids: collections.abc.Iterable[builtins.str] | None = ...,
         frame_number_start: builtins.int = ...,
         frame_time_start: builtins.int = ...,
         annotation_type: proto.clarifai.api.resources_pb2.AnnotationDataType.ValueType = ...,
@@ -525,8 +535,8 @@ class StreamTrackAnnotationsSearchesRequest(google.protobuf.message.Message):
             b"max_duration",
             "max_frames",
             b"max_frames",
-            "track_id",
-            b"track_id",
+            "track_ids",
+            b"track_ids",
             "user_app_id",
             b"user_app_id",
             "worker",
@@ -1059,6 +1069,48 @@ class SingleAnnotationResponse(google.protobuf.message.Message):
 
 global___SingleAnnotationResponse = SingleAnnotationResponse
 
+@typing_extensions.final
+class SingleStreamTrackAnnotationResponse(google.protobuf.message.Message):
+    """SingleStreamTrackAnnotationResponse similar to SingleAnnotationResponse but with an extra field"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    STATUS_FIELD_NUMBER: builtins.int
+    ANNOTATION_FIELD_NUMBER: builtins.int
+    FRAME_FULLY_PROCESSED_FIELD_NUMBER: builtins.int
+    @property
+    def status(self) -> proto.clarifai.api.status.status_pb2.Status: ...
+    @property
+    def annotation(self) -> proto.clarifai.api.resources_pb2.Annotation: ...
+    frame_fully_processed: builtins.bool
+    """Indicates if this frame has been fully processed
+    Needed in case client needs to decide whether to stop and wait for more data or continue playback
+    """
+    def __init__(
+        self,
+        *,
+        status: proto.clarifai.api.status.status_pb2.Status | None = ...,
+        annotation: proto.clarifai.api.resources_pb2.Annotation | None = ...,
+        frame_fully_processed: builtins.bool = ...,
+    ) -> None: ...
+    def HasField(
+        self,
+        field_name: typing_extensions.Literal["annotation", b"annotation", "status", b"status"],
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "annotation",
+            b"annotation",
+            "frame_fully_processed",
+            b"frame_fully_processed",
+            "status",
+            b"status",
+        ],
+    ) -> None: ...
+
+global___SingleStreamTrackAnnotationResponse = SingleStreamTrackAnnotationResponse
+
 @typing_extensions.final
 class MultiAnnotationResponse(google.protobuf.message.Message):
     """MultiAnnotationResponse"""
@@ -5992,13 +6044,15 @@ class GetResourceCountsResponse(google.protobuf.message.Message):
     WORKFLOWS_FIELD_NUMBER: builtins.int
     MODULES_FIELD_NUMBER: builtins.int
     INPUTS_FIELD_NUMBER: builtins.int
+    PIPELINES_FIELD_NUMBER: builtins.int
     @property
     def status(self) -> proto.clarifai.api.status.status_pb2.Status: ...
     datasets: builtins.int
     models: builtins.int
     workflows: builtins.int
     modules: builtins.int
     inputs: builtins.int
+    pipelines: builtins.int
     def __init__(
         self,
         *,
@@ -6008,6 +6062,7 @@ class GetResourceCountsResponse(google.protobuf.message.Message):
         workflows: builtins.int = ...,
         modules: builtins.int = ...,
         inputs: builtins.int = ...,
+        pipelines: builtins.int = ...,
     ) -> None: ...
     def HasField(
         self, field_name: typing_extensions.Literal["status", b"status"]
@@ -6023,6 +6078,8 @@ class GetResourceCountsResponse(google.protobuf.message.Message):
             b"models",
             "modules",
             b"modules",
+            "pipelines",
+            b"pipelines",
             "status",
             b"status",
             "workflows",

clarifai_grpc/grpc/api/service_pb2.py

@@ -132,7 +132,7 @@ def __init__(self, channel):
         self.StreamTrackAnnotationsSearches = channel.unary_stream(
                 '/clarifai.api.V2/StreamTrackAnnotationsSearches',
                 request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.StreamTrackAnnotationsSearchesRequest.SerializeToString,
-                response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.SingleAnnotationResponse),
+                response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.SingleStreamTrackAnnotationResponse),
                 )
         self.PostAnnotations = channel.unary_unary(
                 '/clarifai.api.V2/PostAnnotations',
@@ -3726,7 +3726,7 @@ def add_V2Servicer_to_server(servicer, server):
             'StreamTrackAnnotationsSearches': grpc.unary_stream_rpc_method_handler(
                     servicer.StreamTrackAnnotationsSearches,
                     request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.StreamTrackAnnotationsSearchesRequest.FromString,
-                    response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.SingleAnnotationResponse.SerializeToString,
+                    response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.SingleStreamTrackAnnotationResponse.SerializeToString,
             ),
             'PostAnnotations': grpc.unary_unary_rpc_method_handler(
                     servicer.PostAnnotations,
@@ -5437,7 +5437,7 @@ def StreamTrackAnnotationsSearches(request,
             metadata=None):
         return grpc.experimental.unary_stream(request, target, '/clarifai.api.V2/StreamTrackAnnotationsSearches',
             proto_dot_clarifai_dot_api_dot_service__pb2.StreamTrackAnnotationsSearchesRequest.SerializeToString,
-            proto_dot_clarifai_dot_api_dot_service__pb2.SingleAnnotationResponse.FromString,
+            proto_dot_clarifai_dot_api_dot_service__pb2.SingleStreamTrackAnnotationResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 

clarifai_grpc/grpc/api/service_pb2.pyi

@@ -491,7 +491,11 @@ class _StatusCodeEnumTypeWrapper(
     TASK_FAILED: _StatusCode.ValueType  # 54005
     """An error occurred during add-task-annotations or add-auto-annotations pipeline."""
     TASK_IDLE: _StatusCode.ValueType  # 54006
-    """When an Auto Annotation task job has finished processing its last batch and is waiting for more dataset assets."""
+    """Task is waiting for user action.
+    Examples:
+    - When an Auto Annotation task job has finished processing its last batch and is waiting for more dataset assets.
+    - When an Auto Annotation task job for a video livestream input is waiting for user to create a task deployment.
+    """
     TASK_CONFLICT: _StatusCode.ValueType  # 54100
     """The task operation is in conflict with the current state of the server."""
     TASK_NOT_IMPLEMENTED: _StatusCode.ValueType  # 54101
@@ -576,6 +580,7 @@ class _StatusCodeEnumTypeWrapper(
     JOB_CANCELLED: _StatusCode.ValueType  # 64004
     JOB_UNEXPECTED_ERROR: _StatusCode.ValueType  # 64006
     JOB_CONFLICT: _StatusCode.ValueType  # 64007
+    JOB_PAUSED: _StatusCode.ValueType  # 64008
     AUTH_MISSING_IDP_ASSOC: _StatusCode.ValueType  # 65000
     """auth issues
     TODO: Knowledge graph related 80xxx
@@ -1099,7 +1104,11 @@ TASK_WONT_DO: StatusCode.ValueType  # 54003
 TASK_FAILED: StatusCode.ValueType  # 54005
 """An error occurred during add-task-annotations or add-auto-annotations pipeline."""
 TASK_IDLE: StatusCode.ValueType  # 54006
-"""When an Auto Annotation task job has finished processing its last batch and is waiting for more dataset assets."""
+"""Task is waiting for user action.
+Examples:
+- When an Auto Annotation task job has finished processing its last batch and is waiting for more dataset assets.
+- When an Auto Annotation task job for a video livestream input is waiting for user to create a task deployment.
+"""
 TASK_CONFLICT: StatusCode.ValueType  # 54100
 """The task operation is in conflict with the current state of the server."""
 TASK_NOT_IMPLEMENTED: StatusCode.ValueType  # 54101
@@ -1184,6 +1193,7 @@ JOB_FAILED: StatusCode.ValueType  # 64003
 JOB_CANCELLED: StatusCode.ValueType  # 64004
 JOB_UNEXPECTED_ERROR: StatusCode.ValueType  # 64006
 JOB_CONFLICT: StatusCode.ValueType  # 64007
+JOB_PAUSED: StatusCode.ValueType  # 64008
 AUTH_MISSING_IDP_ASSOC: StatusCode.ValueType  # 65000
 """auth issues
 TODO: Knowledge graph related 80xxx