GRPC clients version 11.10.3

Author: clarifai-prod

clarifai_grpc/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "11.10.2"
+__version__ = "11.10.3"
 
 import os
 

clarifai_grpc/grpc/api/resources_pb2.py

@@ -17217,12 +17217,12 @@ class PipelineVersionConfig(google.protobuf.message.Message):
         VALUE_FIELD_NUMBER: builtins.int
         key: builtins.str
         @property
-        def value(self) -> global___StepSecretConfig: ...
+        def value(self) -> google.protobuf.struct_pb2.Struct: ...
         def __init__(
             self,
             *,
             key: builtins.str = ...,
-            value: global___StepSecretConfig | None = ...,
+            value: google.protobuf.struct_pb2.Struct | None = ...,
         ) -> None: ...
         def HasField(
             self, field_name: typing_extensions.Literal["value", b"value"]
@@ -17235,16 +17235,20 @@ class PipelineVersionConfig(google.protobuf.message.Message):
     @property
     def step_version_secrets(
         self,
-    ) -> google.protobuf.internal.containers.MessageMap[builtins.str, global___StepSecretConfig]:
-        """StepVersionSecrets maps step version references to their secret configurations
-        The outer map key is the step version reference (e.g. "step1" or the step version ID)
-        The inner map key is the secret name (e.g. "EMAIL_PROVIDER_API_KEY")
-        The inner map value is the secret reference (e.g. "users/1/secrets/secret-1")
+    ) -> google.protobuf.internal.containers.MessageMap[
+        builtins.str, google.protobuf.struct_pb2.Struct
+    ]:
+        """StepVersionSecrets maps step names to their secret configurations
+        Using google.protobuf.Struct to create the desired flat JSON structure
+        This produces: {stepName: {secretName: "users/user-name/secrets/key"}}
+        example: {"step-0": {"API_KEY": "users/user-name/secrets/key"}}
         """
     def __init__(
         self,
         *,
-        step_version_secrets: collections.abc.Mapping[builtins.str, global___StepSecretConfig]
+        step_version_secrets: collections.abc.Mapping[
+            builtins.str, google.protobuf.struct_pb2.Struct
+        ]
         | None = ...,
     ) -> None: ...
     def ClearField(
@@ -17254,43 +17258,6 @@ class PipelineVersionConfig(google.protobuf.message.Message):
 
 global___PipelineVersionConfig = PipelineVersionConfig
 
-@typing_extensions.final
-class StepSecretConfig(google.protobuf.message.Message):
-    """StepSecretConfig defines secrets for a specific step version"""
-
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-
-    @typing_extensions.final
-    class SecretsEntry(google.protobuf.message.Message):
-        DESCRIPTOR: google.protobuf.descriptor.Descriptor
-
-        KEY_FIELD_NUMBER: builtins.int
-        VALUE_FIELD_NUMBER: builtins.int
-        key: builtins.str
-        value: builtins.str
-        def __init__(
-            self,
-            *,
-            key: builtins.str = ...,
-            value: builtins.str = ...,
-        ) -> None: ...
-        def ClearField(
-            self, field_name: typing_extensions.Literal["key", b"key", "value", b"value"]
-        ) -> None: ...
-
-    SECRETS_FIELD_NUMBER: builtins.int
-    @property
-    def secrets(self) -> google.protobuf.internal.containers.ScalarMap[builtins.str, builtins.str]:
-        """Map of secret name to secret reference"""
-    def __init__(
-        self,
-        *,
-        secrets: collections.abc.Mapping[builtins.str, builtins.str] | None = ...,
-    ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["secrets", b"secrets"]) -> None: ...
-
-global___StepSecretConfig = StepSecretConfig
-
 @typing_extensions.final
 class PipelineVersion(google.protobuf.message.Message):
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
@@ -17495,7 +17462,9 @@ class PipelineVersionRun(google.protobuf.message.Message):
         """Optional: Overrides to input arguments for the orchestration system."""
     @property
     def orchestration_spec(self) -> global___OrchestrationSpec:
-        """Final merged orchestration spec snapshot submitted to backend."""
+        """Final merged orchestration spec snapshot submitted to backend.
+        This field is read-only and cannot be set during creation.
+        """
     def __init__(
         self,
         *,

clarifai_grpc/grpc/api/resources_pb2.pyi

@@ -15405,6 +15405,52 @@ class PostComputeClustersRequest(google.protobuf.message.Message):
 
 global___PostComputeClustersRequest = PostComputeClustersRequest
 
+@typing_extensions.final
+class PatchComputeClustersRequest(google.protobuf.message.Message):
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    USER_APP_ID_FIELD_NUMBER: builtins.int
+    COMPUTE_CLUSTERS_FIELD_NUMBER: builtins.int
+    ACTION_FIELD_NUMBER: builtins.int
+    @property
+    def user_app_id(self) -> proto.clarifai.api.resources_pb2.UserAppIDSet:
+        """Only the user_id is used from this."""
+    @property
+    def compute_clusters(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
+        proto.clarifai.api.resources_pb2.ComputeCluster
+    ]:
+        """This allows you to patch one or more compute_clusters"""
+    action: builtins.str
+    """The action to perform on the patched objects
+    For now 'overwrite' is supported
+    """
+    def __init__(
+        self,
+        *,
+        user_app_id: proto.clarifai.api.resources_pb2.UserAppIDSet | None = ...,
+        compute_clusters: collections.abc.Iterable[proto.clarifai.api.resources_pb2.ComputeCluster]
+        | None = ...,
+        action: builtins.str = ...,
+    ) -> 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[
+            "action",
+            b"action",
+            "compute_clusters",
+            b"compute_clusters",
+            "user_app_id",
+            b"user_app_id",
+        ],
+    ) -> None: ...
+
+global___PatchComputeClustersRequest = PatchComputeClustersRequest
+
 @typing_extensions.final
 class DeleteComputeClustersRequest(google.protobuf.message.Message):
     DESCRIPTOR: google.protobuf.descriptor.Descriptor

clarifai_grpc/grpc/api/service_pb2.py

@@ -1204,6 +1204,11 @@ def __init__(self, channel):
                 request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.DeleteComputeClustersRequest.SerializeToString,
                 response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_status_dot_status__pb2.BaseResponse),
                 )
+        self.PatchComputeClusters = channel.unary_unary(
+                '/clarifai.api.V2/PatchComputeClusters',
+                request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.PatchComputeClustersRequest.SerializeToString,
+                response_deserializer=wrap_response_deserializer(proto_dot_clarifai_dot_api_dot_service__pb2.MultiComputeClusterResponse),
+                )
         self.GetNodepool = channel.unary_unary(
                 '/clarifai.api.V2/GetNodepool',
                 request_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.GetNodepoolRequest.SerializeToString,
@@ -3242,6 +3247,12 @@ def DeleteComputeClusters(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def PatchComputeClusters(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 GetNodepool(self, request, context):
         """Nodepools CRUD
         """
@@ -4708,6 +4719,11 @@ def add_V2Servicer_to_server(servicer, server):
                     request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.DeleteComputeClustersRequest.FromString,
                     response_serializer=proto_dot_clarifai_dot_api_dot_status_dot_status__pb2.BaseResponse.SerializeToString,
             ),
+            'PatchComputeClusters': grpc.unary_unary_rpc_method_handler(
+                    servicer.PatchComputeClusters,
+                    request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.PatchComputeClustersRequest.FromString,
+                    response_serializer=proto_dot_clarifai_dot_api_dot_service__pb2.MultiComputeClusterResponse.SerializeToString,
+            ),
             'GetNodepool': grpc.unary_unary_rpc_method_handler(
                     servicer.GetNodepool,
                     request_deserializer=proto_dot_clarifai_dot_api_dot_service__pb2.GetNodepoolRequest.FromString,
@@ -8949,6 +8965,23 @@ def DeleteComputeClusters(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
+    @staticmethod
+    def PatchComputeClusters(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/PatchComputeClusters',
+            proto_dot_clarifai_dot_api_dot_service__pb2.PatchComputeClustersRequest.SerializeToString,
+            proto_dot_clarifai_dot_api_dot_service__pb2.MultiComputeClusterResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
     @staticmethod
     def GetNodepool(request,
             target,