Version 6.7.0

Author: rok-clarifai

VERSION

@@ -1 +1 @@
-6.6.0
+6.7.0

clarifai_grpc/channel/http_client.py

@@ -8,7 +8,7 @@
 
 from clarifai_grpc.channel.errors import ApiError
 
-CLIENT_VERSION = '6.6.0'
+CLIENT_VERSION = '6.7.0'
 OS_VER = os.sys.platform
 PYTHON_VERSION = '.'.join(
     map(str, [os.sys.version_info.major, os.sys.version_info.minor, os.sys.version_info.micro]))

clarifai_grpc/grpc/api/resources_pb2.py

@@ -338,6 +338,23 @@ class App(google___protobuf___message___Message):
     def ClearField(self, field_name: typing_extensions___Literal[u"created_at",b"created_at",u"default_language",b"default_language",u"default_workflow_id",b"default_workflow_id",u"description",b"description",u"id",b"id",u"legal_consent_status",b"legal_consent_status",u"metadata",b"metadata",u"name",b"name",u"sample_ms",b"sample_ms",u"user_id",b"user_id"]) -> None: ...
 type___App = App
 
+class AppQuery(google___protobuf___message___Message):
+    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
+    name: typing___Text = ...
+
+    def __init__(self,
+        *,
+        name : typing___Optional[typing___Text] = None,
+        ) -> None: ...
+    if sys.version_info >= (3,):
+        @classmethod
+        def FromString(cls, s: builtin___bytes) -> AppQuery: ...
+    else:
+        @classmethod
+        def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> AppQuery: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"name",b"name"]) -> None: ...
+type___AppQuery = AppQuery
+
 class Collaborator(google___protobuf___message___Message):
     DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
     id: typing___Text = ...
@@ -1549,6 +1566,7 @@ class ModelTypeField(google___protobuf___message___Message):
         COLLABORATORS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 9)
         JSON = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 10)
         ARRAY_OF_NUMBERS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 11)
+        WORKFLOW_EMBED_MODELS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 12)
     INVALID_MODEL_TYPE_FIELD_TYPE = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 0)
     BOOLEAN = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 1)
     STRING = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 2)
@@ -1560,20 +1578,25 @@ class ModelTypeField(google___protobuf___message___Message):
     COLLABORATORS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 9)
     JSON = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 10)
     ARRAY_OF_NUMBERS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 11)
+    WORKFLOW_EMBED_MODELS = typing___cast(ModelTypeField.ModelTypeFieldTypeValue, 12)
     type___ModelTypeFieldType = ModelTypeFieldType
 
     path: typing___Text = ...
     field_type: type___ModelTypeField.ModelTypeFieldTypeValue = ...
     description: typing___Text = ...
     placeholder: typing___Text = ...
     internal_only: builtin___bool = ...
+    required: builtin___bool = ...
 
     @property
     def default_value(self) -> google___protobuf___struct_pb2___Value: ...
 
     @property
     def model_type_enum_options(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ModelTypeEnumOption]: ...
 
+    @property
+    def model_type_range_info(self) -> type___ModelTypeRangeInfo: ...
+
     def __init__(self,
         *,
         path : typing___Optional[typing___Text] = None,
@@ -1583,17 +1606,40 @@ class ModelTypeField(google___protobuf___message___Message):
         placeholder : typing___Optional[typing___Text] = None,
         model_type_enum_options : typing___Optional[typing___Iterable[type___ModelTypeEnumOption]] = None,
         internal_only : typing___Optional[builtin___bool] = None,
+        required : typing___Optional[builtin___bool] = None,
+        model_type_range_info : typing___Optional[type___ModelTypeRangeInfo] = None,
         ) -> None: ...
     if sys.version_info >= (3,):
         @classmethod
         def FromString(cls, s: builtin___bytes) -> ModelTypeField: ...
     else:
         @classmethod
         def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> ModelTypeField: ...
-    def HasField(self, field_name: typing_extensions___Literal[u"default_value",b"default_value"]) -> builtin___bool: ...
-    def ClearField(self, field_name: typing_extensions___Literal[u"default_value",b"default_value",u"description",b"description",u"field_type",b"field_type",u"internal_only",b"internal_only",u"model_type_enum_options",b"model_type_enum_options",u"path",b"path",u"placeholder",b"placeholder"]) -> None: ...
+    def HasField(self, field_name: typing_extensions___Literal[u"default_value",b"default_value",u"model_type_range_info",b"model_type_range_info"]) -> builtin___bool: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"default_value",b"default_value",u"description",b"description",u"field_type",b"field_type",u"internal_only",b"internal_only",u"model_type_enum_options",b"model_type_enum_options",u"model_type_range_info",b"model_type_range_info",u"path",b"path",u"placeholder",b"placeholder",u"required",b"required"]) -> None: ...
 type___ModelTypeField = ModelTypeField
 
+class ModelTypeRangeInfo(google___protobuf___message___Message):
+    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
+    min: builtin___float = ...
+    max: builtin___float = ...
+    step: builtin___float = ...
+
+    def __init__(self,
+        *,
+        min : typing___Optional[builtin___float] = None,
+        max : typing___Optional[builtin___float] = None,
+        step : typing___Optional[builtin___float] = None,
+        ) -> None: ...
+    if sys.version_info >= (3,):
+        @classmethod
+        def FromString(cls, s: builtin___bytes) -> ModelTypeRangeInfo: ...
+    else:
+        @classmethod
+        def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> ModelTypeRangeInfo: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"max",b"max",u"min",b"min",u"step",b"step"]) -> None: ...
+type___ModelTypeRangeInfo = ModelTypeRangeInfo
+
 class ModelTypeEnumOption(google___protobuf___message___Message):
     DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
     id: typing___Text = ...
@@ -1623,19 +1669,21 @@ class ModelQuery(google___protobuf___message___Message):
     DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
     name: typing___Text = ...
     type: typing___Text = ...
+    model_type_id: typing___Text = ...
 
     def __init__(self,
         *,
         name : typing___Optional[typing___Text] = None,
         type : typing___Optional[typing___Text] = None,
+        model_type_id : typing___Optional[typing___Text] = None,
         ) -> None: ...
     if sys.version_info >= (3,):
         @classmethod
         def FromString(cls, s: builtin___bytes) -> ModelQuery: ...
     else:
         @classmethod
         def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> ModelQuery: ...
-    def ClearField(self, field_name: typing_extensions___Literal[u"name",b"name",u"type",b"type"]) -> None: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"model_type_id",b"model_type_id",u"name",b"name",u"type",b"type"]) -> None: ...
 type___ModelQuery = ModelQuery
 
 class ModelVersion(google___protobuf___message___Message):
@@ -1682,6 +1730,7 @@ class PretrainedModelConfig(google___protobuf___message___Message):
     type: typing___Text = ...
     data_provider_params: typing___Text = ...
     model_zip_url: typing___Text = ...
+    overwrite: builtin___bool = ...
 
     @property
     def input_fields_map(self) -> google___protobuf___struct_pb2___Struct: ...
@@ -1697,6 +1746,7 @@ class PretrainedModelConfig(google___protobuf___message___Message):
         output_fields_map : typing___Optional[google___protobuf___struct_pb2___Struct] = None,
         data_provider_params : typing___Optional[typing___Text] = None,
         model_zip_url : typing___Optional[typing___Text] = None,
+        overwrite : typing___Optional[builtin___bool] = None,
         ) -> None: ...
     if sys.version_info >= (3,):
         @classmethod
@@ -1705,7 +1755,7 @@ class PretrainedModelConfig(google___protobuf___message___Message):
         @classmethod
         def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> PretrainedModelConfig: ...
     def HasField(self, field_name: typing_extensions___Literal[u"input_fields_map",b"input_fields_map",u"output_fields_map",b"output_fields_map"]) -> builtin___bool: ...
-    def ClearField(self, field_name: typing_extensions___Literal[u"data_provider_params",b"data_provider_params",u"id",b"id",u"input_fields_map",b"input_fields_map",u"model_zip_url",b"model_zip_url",u"output_fields_map",b"output_fields_map",u"type",b"type"]) -> None: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"data_provider_params",b"data_provider_params",u"id",b"id",u"input_fields_map",b"input_fields_map",u"model_zip_url",b"model_zip_url",u"output_fields_map",b"output_fields_map",u"overwrite",b"overwrite",u"type",b"type"]) -> None: ...
 type___PretrainedModelConfig = PretrainedModelConfig
 
 class TrainStats(google___protobuf___message___Message):
@@ -2880,28 +2930,82 @@ class TaskWorker(google___protobuf___message___Message):
         @classmethod
         def items(cls) -> typing___List[typing___Tuple[builtin___str, TaskWorker.TaskWorkerStrategyValue]]: ...
         WORKER_STRATEGY_NOT_SET = typing___cast(TaskWorker.TaskWorkerStrategyValue, 0)
-        MANUAL = typing___cast(TaskWorker.TaskWorkerStrategyValue, 1)
+        PARTITIONED = typing___cast(TaskWorker.TaskWorkerStrategyValue, 2)
+        FULL = typing___cast(TaskWorker.TaskWorkerStrategyValue, 3)
     WORKER_STRATEGY_NOT_SET = typing___cast(TaskWorker.TaskWorkerStrategyValue, 0)
-    MANUAL = typing___cast(TaskWorker.TaskWorkerStrategyValue, 1)
+    PARTITIONED = typing___cast(TaskWorker.TaskWorkerStrategyValue, 2)
+    FULL = typing___cast(TaskWorker.TaskWorkerStrategyValue, 3)
     type___TaskWorkerStrategy = TaskWorkerStrategy
 
     strategy: type___TaskWorker.TaskWorkerStrategyValue = ...
     user_ids: google___protobuf___internal___containers___RepeatedScalarFieldContainer[typing___Text] = ...
 
+    @property
+    def partitioned_strategy_info(self) -> type___TaskWorkerPartitionedStrategyInfo: ...
+
     def __init__(self,
         *,
         strategy : typing___Optional[type___TaskWorker.TaskWorkerStrategyValue] = None,
         user_ids : typing___Optional[typing___Iterable[typing___Text]] = None,
+        partitioned_strategy_info : typing___Optional[type___TaskWorkerPartitionedStrategyInfo] = None,
         ) -> None: ...
     if sys.version_info >= (3,):
         @classmethod
         def FromString(cls, s: builtin___bytes) -> TaskWorker: ...
     else:
         @classmethod
         def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> TaskWorker: ...
-    def ClearField(self, field_name: typing_extensions___Literal[u"strategy",b"strategy",u"user_ids",b"user_ids"]) -> None: ...
+    def HasField(self, field_name: typing_extensions___Literal[u"partitioned_strategy_info",b"partitioned_strategy_info",u"strategy_info",b"strategy_info"]) -> builtin___bool: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"partitioned_strategy_info",b"partitioned_strategy_info",u"strategy",b"strategy",u"strategy_info",b"strategy_info",u"user_ids",b"user_ids"]) -> None: ...
+    def WhichOneof(self, oneof_group: typing_extensions___Literal[u"strategy_info",b"strategy_info"]) -> typing_extensions___Literal["partitioned_strategy_info"]: ...
 type___TaskWorker = TaskWorker
 
+class TaskWorkerPartitionedStrategyInfo(google___protobuf___message___Message):
+    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
+    TaskWorkerPartitionedStrategyValue = typing___NewType('TaskWorkerPartitionedStrategyValue', builtin___int)
+    type___TaskWorkerPartitionedStrategyValue = TaskWorkerPartitionedStrategyValue
+    class TaskWorkerPartitionedStrategy(object):
+        DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ...
+        @classmethod
+        def Name(cls, number: builtin___int) -> builtin___str: ...
+        @classmethod
+        def Value(cls, name: builtin___str) -> TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue: ...
+        @classmethod
+        def keys(cls) -> typing___List[builtin___str]: ...
+        @classmethod
+        def values(cls) -> typing___List[TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue]: ...
+        @classmethod
+        def items(cls) -> typing___List[typing___Tuple[builtin___str, TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue]]: ...
+        PARTITIONED_WORKER_STRATEGY_NOT_SET = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 0)
+        EVENLY = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 1)
+        WEIGHTED = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 2)
+    PARTITIONED_WORKER_STRATEGY_NOT_SET = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 0)
+    EVENLY = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 1)
+    WEIGHTED = typing___cast(TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue, 2)
+    type___TaskWorkerPartitionedStrategy = TaskWorkerPartitionedStrategy
+
+    type: type___TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue = ...
+    workers_per_input: builtin___int = ...
+
+    @property
+    def weights(self) -> google___protobuf___struct_pb2___Struct: ...
+
+    def __init__(self,
+        *,
+        type : typing___Optional[type___TaskWorkerPartitionedStrategyInfo.TaskWorkerPartitionedStrategyValue] = None,
+        workers_per_input : typing___Optional[builtin___int] = None,
+        weights : typing___Optional[google___protobuf___struct_pb2___Struct] = None,
+        ) -> None: ...
+    if sys.version_info >= (3,):
+        @classmethod
+        def FromString(cls, s: builtin___bytes) -> TaskWorkerPartitionedStrategyInfo: ...
+    else:
+        @classmethod
+        def FromString(cls, s: typing___Union[builtin___bytes, builtin___buffer, builtin___unicode]) -> TaskWorkerPartitionedStrategyInfo: ...
+    def HasField(self, field_name: typing_extensions___Literal[u"weights",b"weights"]) -> builtin___bool: ...
+    def ClearField(self, field_name: typing_extensions___Literal[u"type",b"type",u"weights",b"weights",u"workers_per_input",b"workers_per_input"]) -> None: ...
+type___TaskWorkerPartitionedStrategyInfo = TaskWorkerPartitionedStrategyInfo
+
 class TaskInputSource(google___protobuf___message___Message):
     DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
     TaskInputSourceTypeValue = typing___NewType('TaskInputSourceTypeValue', builtin___int)