Skip to content

Commit

Permalink
chore: auto-gen by protobufs
Browse files Browse the repository at this point in the history
triggered by commit: instill-ai/protobufs@bbbeead
  • Loading branch information
droplet-bot committed Nov 29, 2024
1 parent 1458fe9 commit 8273e1f
Show file tree
Hide file tree
Showing 11 changed files with 143 additions and 133 deletions.
38 changes: 19 additions & 19 deletions artifact/artifact/v1alpha/artifact_public_service_pb2.py

Large diffs are not rendered by default.

30 changes: 14 additions & 16 deletions model/model/v1alpha/model_pb2.py

Large diffs are not rendered by default.

18 changes: 7 additions & 11 deletions model/model/v1alpha/model_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -3736,7 +3736,6 @@ class ModelRun(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor

UID_FIELD_NUMBER: builtins.int
MODEL_UID_FIELD_NUMBER: builtins.int
STATUS_FIELD_NUMBER: builtins.int
SOURCE_FIELD_NUMBER: builtins.int
TOTAL_DURATION_FIELD_NUMBER: builtins.int
Expand All @@ -3751,11 +3750,9 @@ class ModelRun(google.protobuf.message.Message):
TASK_OUTPUTS_FIELD_NUMBER: builtins.int
MODEL_ID_FIELD_NUMBER: builtins.int
REQUESTER_ID_FIELD_NUMBER: builtins.int
NAMESPACE_ID_FIELD_NUMBER: builtins.int
MODEL_NAMESPACE_ID_FIELD_NUMBER: builtins.int
uid: builtins.str
"""Model Run UUID."""
model_uid: builtins.str
"""Model UUID."""
status: common.run.v1alpha.run_pb2.RunStatus.ValueType
"""Model run status."""
source: common.run.v1alpha.run_pb2.RunSource.ValueType
Expand Down Expand Up @@ -3788,16 +3785,15 @@ class ModelRun(google.protobuf.message.Message):
model_id: builtins.str
"""Model ID."""
requester_id: builtins.str
"""Requester ID. This field might be empty if the model run belongs to a
deleted namespace.
"""Requester ID. The namespace used to trigger the run. This field might be
empty if the model run belongs to a deleted namespace.
"""
namespace_id: builtins.str
"""Namespace ID."""
model_namespace_id: builtins.str
"""ID of the namespace that owns the model."""
def __init__(
self,
*,
uid: builtins.str = ...,
model_uid: builtins.str = ...,
status: common.run.v1alpha.run_pb2.RunStatus.ValueType = ...,
source: common.run.v1alpha.run_pb2.RunSource.ValueType = ...,
total_duration: builtins.int | None = ...,
Expand All @@ -3812,10 +3808,10 @@ class ModelRun(google.protobuf.message.Message):
task_outputs: collections.abc.Iterable[google.protobuf.struct_pb2.Struct] | None = ...,
model_id: builtins.str | None = ...,
requester_id: builtins.str = ...,
namespace_id: builtins.str = ...,
model_namespace_id: builtins.str = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["_credit_amount", b"_credit_amount", "_end_time", b"_end_time", "_error", b"_error", "_model_id", b"_model_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "create_time", b"create_time", "credit_amount", b"credit_amount", "end_time", b"end_time", "error", b"error", "model_id", b"model_id", "runner_id", b"runner_id", "total_duration", b"total_duration", "update_time", b"update_time"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["_credit_amount", b"_credit_amount", "_end_time", b"_end_time", "_error", b"_error", "_model_id", b"_model_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "create_time", b"create_time", "credit_amount", b"credit_amount", "end_time", b"end_time", "error", b"error", "model_id", b"model_id", "model_uid", b"model_uid", "namespace_id", b"namespace_id", "requester_id", b"requester_id", "runner_id", b"runner_id", "source", b"source", "status", b"status", "task_inputs", b"task_inputs", "task_outputs", b"task_outputs", "total_duration", b"total_duration", "uid", b"uid", "update_time", b"update_time", "version", b"version"]) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["_credit_amount", b"_credit_amount", "_end_time", b"_end_time", "_error", b"_error", "_model_id", b"_model_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "create_time", b"create_time", "credit_amount", b"credit_amount", "end_time", b"end_time", "error", b"error", "model_id", b"model_id", "model_namespace_id", b"model_namespace_id", "requester_id", b"requester_id", "runner_id", b"runner_id", "source", b"source", "status", b"status", "task_inputs", b"task_inputs", "task_outputs", b"task_outputs", "total_duration", b"total_duration", "uid", b"uid", "update_time", b"update_time", "version", b"version"]) -> None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_credit_amount", b"_credit_amount"]) -> typing_extensions.Literal["credit_amount"] | None: ...
@typing.overload
Expand Down
20 changes: 10 additions & 10 deletions model/model/v1alpha/model_public_service_pb2.py

Large diffs are not rendered by default.

14 changes: 9 additions & 5 deletions model/model/v1alpha/model_public_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -931,19 +931,23 @@ def GetOrganizationLatestModelOperation(self, request, context):
raise NotImplementedError('Method not implemented!')

def ListModelRuns(self, request, context):
"""List model runs
"""List Model Runs
Returns a paginated list of model runs.
Returns a paginated list of runs for a given model. When the requester is
the owner of the model, they will be able to all the model runs,
regardless who requested the trigger (the view will be partial to hide
sensitive data like e.g. the trigger input and output). Other requesters
will only be able to see the runs requested by themselves.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def ListModelRunsByRequester(self, request, context):
"""List Model Runs of a Namespace (user or organization)
"""List Model Runs By Requester
Returns a paginated list of runs for 1 or more models. This is mainly used by dashboard.
The requester can view all the runs by the requester across different models.
Returns a paginated list of runs requested by a namespace. The response
may contain runs from several models.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
Expand Down
42 changes: 27 additions & 15 deletions model/model/v1alpha/model_public_service_pb2_grpc.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -574,18 +574,22 @@ class ModelPublicServiceStub:
model.model.v1alpha.model_pb2.ListModelRunsRequest,
model.model.v1alpha.model_pb2.ListModelRunsResponse,
]
"""List model runs
"""List Model Runs
Returns a paginated list of model runs.
Returns a paginated list of runs for a given model. When the requester is
the owner of the model, they will be able to all the model runs,
regardless who requested the trigger (the view will be partial to hide
sensitive data like e.g. the trigger input and output). Other requesters
will only be able to see the runs requested by themselves.
"""
ListModelRunsByRequester: grpc.UnaryUnaryMultiCallable[
model.model.v1alpha.model_pb2.ListModelRunsByRequesterRequest,
model.model.v1alpha.model_pb2.ListModelRunsByRequesterResponse,
]
"""List Model Runs of a Namespace (user or organization)
"""List Model Runs By Requester
Returns a paginated list of runs for 1 or more models. This is mainly used by dashboard.
The requester can view all the runs by the requester across different models.
Returns a paginated list of runs requested by a namespace. The response
may contain runs from several models.
"""

class ModelPublicServiceAsyncStub:
Expand Down Expand Up @@ -1143,18 +1147,22 @@ class ModelPublicServiceAsyncStub:
model.model.v1alpha.model_pb2.ListModelRunsRequest,
model.model.v1alpha.model_pb2.ListModelRunsResponse,
]
"""List model runs
"""List Model Runs
Returns a paginated list of model runs.
Returns a paginated list of runs for a given model. When the requester is
the owner of the model, they will be able to all the model runs,
regardless who requested the trigger (the view will be partial to hide
sensitive data like e.g. the trigger input and output). Other requesters
will only be able to see the runs requested by themselves.
"""
ListModelRunsByRequester: grpc.aio.UnaryUnaryMultiCallable[
model.model.v1alpha.model_pb2.ListModelRunsByRequesterRequest,
model.model.v1alpha.model_pb2.ListModelRunsByRequesterResponse,
]
"""List Model Runs of a Namespace (user or organization)
"""List Model Runs By Requester
Returns a paginated list of runs for 1 or more models. This is mainly used by dashboard.
The requester can view all the runs by the requester across different models.
Returns a paginated list of runs requested by a namespace. The response
may contain runs from several models.
"""

class ModelPublicServiceServicer(metaclass=abc.ABCMeta):
Expand Down Expand Up @@ -1830,20 +1838,24 @@ class ModelPublicServiceServicer(metaclass=abc.ABCMeta):
request: model.model.v1alpha.model_pb2.ListModelRunsRequest,
context: _ServicerContext,
) -> typing.Union[model.model.v1alpha.model_pb2.ListModelRunsResponse, collections.abc.Awaitable[model.model.v1alpha.model_pb2.ListModelRunsResponse]]:
"""List model runs
"""List Model Runs
Returns a paginated list of model runs.
Returns a paginated list of runs for a given model. When the requester is
the owner of the model, they will be able to all the model runs,
regardless who requested the trigger (the view will be partial to hide
sensitive data like e.g. the trigger input and output). Other requesters
will only be able to see the runs requested by themselves.
"""
@abc.abstractmethod
def ListModelRunsByRequester(
self,
request: model.model.v1alpha.model_pb2.ListModelRunsByRequesterRequest,
context: _ServicerContext,
) -> typing.Union[model.model.v1alpha.model_pb2.ListModelRunsByRequesterResponse, collections.abc.Awaitable[model.model.v1alpha.model_pb2.ListModelRunsByRequesterResponse]]:
"""List Model Runs of a Namespace (user or organization)
"""List Model Runs By Requester
Returns a paginated list of runs for 1 or more models. This is mainly used by dashboard.
The requester can view all the runs by the requester across different models.
Returns a paginated list of runs requested by a namespace. The response
may contain runs from several models.
"""

def add_ModelPublicServiceServicer_to_server(servicer: ModelPublicServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...
18 changes: 8 additions & 10 deletions vdp/pipeline/v1beta/pipeline_pb2.py

Large diffs are not rendered by default.

22 changes: 10 additions & 12 deletions vdp/pipeline/v1beta/pipeline_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -4802,7 +4802,6 @@ class PipelineRun(google.protobuf.message.Message):

DESCRIPTOR: google.protobuf.descriptor.Descriptor

PIPELINE_UID_FIELD_NUMBER: builtins.int
PIPELINE_RUN_UID_FIELD_NUMBER: builtins.int
PIPELINE_VERSION_FIELD_NUMBER: builtins.int
STATUS_FIELD_NUMBER: builtins.int
Expand All @@ -4819,9 +4818,7 @@ class PipelineRun(google.protobuf.message.Message):
DATA_SPECIFICATION_FIELD_NUMBER: builtins.int
PIPELINE_ID_FIELD_NUMBER: builtins.int
REQUESTER_ID_FIELD_NUMBER: builtins.int
NAMESPACE_ID_FIELD_NUMBER: builtins.int
pipeline_uid: builtins.str
"""Unique identifier for the pipeline."""
PIPELINE_NAMESPACE_ID_FIELD_NUMBER: builtins.int
pipeline_run_uid: builtins.str
"""Unique identifier for each run."""
pipeline_version: builtins.str
Expand All @@ -4833,7 +4830,9 @@ class PipelineRun(google.protobuf.message.Message):
total_duration: builtins.int
"""Time taken to complete the run in milliseconds."""
runner_id: builtins.str
"""Runner ID. If current viewing requester does not have enough permission, it will return null."""
"""Runner ID. The authenticated user that triggered the run. If current
viewing requester does not have enough permission, it will return null.
"""
@property
def inputs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[google.protobuf.struct_pb2.Struct]:
"""Pipeline input parameters."""
Expand All @@ -4859,15 +4858,14 @@ class PipelineRun(google.protobuf.message.Message):
pipeline_id: builtins.str
"""The ID of the pipeline"""
requester_id: builtins.str
"""Requester ID. This field might be empty if the pipeline run belongs to a
deleted namespace.
"""Requester ID. The namespace used to trigger the run. This field might be
empty if the pipeline run belongs to a deleted namespace.
"""
namespace_id: builtins.str
"""Namespace ID"""
pipeline_namespace_id: builtins.str
"""ID of the namespace that owns the pipeline."""
def __init__(
self,
*,
pipeline_uid: builtins.str = ...,
pipeline_run_uid: builtins.str = ...,
pipeline_version: builtins.str = ...,
status: common.run.v1alpha.run_pb2.RunStatus.ValueType = ...,
Expand All @@ -4884,10 +4882,10 @@ class PipelineRun(google.protobuf.message.Message):
data_specification: vdp.pipeline.v1beta.component_definition_pb2.DataSpecification | None = ...,
pipeline_id: builtins.str | None = ...,
requester_id: builtins.str = ...,
namespace_id: builtins.str = ...,
pipeline_namespace_id: builtins.str = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["_complete_time", b"_complete_time", "_credit_amount", b"_credit_amount", "_error", b"_error", "_pipeline_id", b"_pipeline_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "complete_time", b"complete_time", "credit_amount", b"credit_amount", "data_specification", b"data_specification", "error", b"error", "pipeline_id", b"pipeline_id", "recipe_snapshot", b"recipe_snapshot", "runner_id", b"runner_id", "start_time", b"start_time", "total_duration", b"total_duration"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["_complete_time", b"_complete_time", "_credit_amount", b"_credit_amount", "_error", b"_error", "_pipeline_id", b"_pipeline_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "complete_time", b"complete_time", "credit_amount", b"credit_amount", "data_specification", b"data_specification", "error", b"error", "inputs", b"inputs", "namespace_id", b"namespace_id", "outputs", b"outputs", "pipeline_id", b"pipeline_id", "pipeline_run_uid", b"pipeline_run_uid", "pipeline_uid", b"pipeline_uid", "pipeline_version", b"pipeline_version", "recipe_snapshot", b"recipe_snapshot", "requester_id", b"requester_id", "runner_id", b"runner_id", "source", b"source", "start_time", b"start_time", "status", b"status", "total_duration", b"total_duration"]) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["_complete_time", b"_complete_time", "_credit_amount", b"_credit_amount", "_error", b"_error", "_pipeline_id", b"_pipeline_id", "_runner_id", b"_runner_id", "_total_duration", b"_total_duration", "complete_time", b"complete_time", "credit_amount", b"credit_amount", "data_specification", b"data_specification", "error", b"error", "inputs", b"inputs", "outputs", b"outputs", "pipeline_id", b"pipeline_id", "pipeline_namespace_id", b"pipeline_namespace_id", "pipeline_run_uid", b"pipeline_run_uid", "pipeline_version", b"pipeline_version", "recipe_snapshot", b"recipe_snapshot", "requester_id", b"requester_id", "runner_id", b"runner_id", "source", b"source", "start_time", b"start_time", "status", b"status", "total_duration", b"total_duration"]) -> None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_complete_time", b"_complete_time"]) -> typing_extensions.Literal["complete_time"] | None: ...
@typing.overload
Expand Down
22 changes: 11 additions & 11 deletions vdp/pipeline/v1beta/pipeline_public_service_pb2.py

Large diffs are not rendered by default.

13 changes: 7 additions & 6 deletions vdp/pipeline/v1beta/pipeline_public_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -1472,15 +1472,16 @@ def ListPipelineRuns(self, request, context):
Returns a paginated list of runs for a given pipeline. When the requester
is the owner of the pipeline, they will be able to all the pipeline runs,
regardless the requester. Other requesters will only be able to see the
runs requested by themselves.
regardless who requested the trigger (the view will be partial to hide
sensitive data like e.g. the trigger input and output). Other requesters
will only be able to see the runs requested by themselves.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def ListComponentRuns(self, request, context):
"""List Component runs
"""List Component Runs
Returns the information of each component execution within a pipeline run.
"""
Expand All @@ -1489,10 +1490,10 @@ def ListComponentRuns(self, request, context):
raise NotImplementedError('Method not implemented!')

def ListPipelineRunsByRequester(self, request, context):
"""List Pipeline Runs of a Namespace (user or organization)
"""List Pipeline Runs By Requester
Returns a paginated list of runs for 1 or more pipelines. This is mainly used by dashboard.
The requester can view all the runs by the requester across different pipelines.
Returns a paginated list of runs for requested by a namespace. The
response may contain runs from several pipelines.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
Expand Down
Loading

0 comments on commit 8273e1f

Please sign in to comment.