Skip to content

Commit b6bf6dc

Browse files
gcf-owl-bot[bot]gcf-merge-on-green[bot]dizcology
authored
feat: Client libraries for the Dataform API (#1221)
* chore(ruby): Initial generation of google-iam-v1 PiperOrigin-RevId: 448073008 Source-Link: googleapis/googleapis@d664bc5 Source-Link: googleapis/googleapis-gen@73f6abc Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNzNmNmFiYzE0MWQyYmI3MjZjMDdjODExZmQ4MWRlMDY3Zjk3ZjY0ZSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add display_name and metadata to ModelEvaluation in aiplatform model_evaluation.proto PiperOrigin-RevId: 448160148 Source-Link: googleapis/googleapis@936ab35 Source-Link: googleapis/googleapis-gen@f841b8e Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZjg0MWI4ZTIzZDgxNmU5OThmOWU4ZTZjMGUwNGJhOTJiN2Y2YjgzNSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: refreshes Bigtable Admin API(s) protos PiperOrigin-RevId: 448988001 Source-Link: googleapis/googleapis@b6fa58e Source-Link: googleapis/googleapis-gen@fc8b8db Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZmM4YjhkYmM3ZGExYTc4NDVkNTcxMzRmNDExMzAyZDEwNmVhMmVmMiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * Synchronize new proto/yaml changes. PiperOrigin-RevId: 449052112 Source-Link: googleapis/googleapis@3150afa Source-Link: googleapis/googleapis-gen@9945a36 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOTk0NWEzNjZlNGE1ZWZiMDBmYzQwOTg1ZjAzYzEwN2JkZWU4OWRmMiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * docs: fix docstring formatting Committer: parthea PiperOrigin-RevId: 449545643 Source-Link: googleapis/googleapis@1bed8a0 Source-Link: googleapis/googleapis-gen@d4ccc5f Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZDRjY2M1ZmM2MTJjMjYwNTQ2YmNlY2VmMjg3MzU3NTY4OGEwMmQ4YiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add Examples to Explanation related messages in aiplatform v1beta1 explanation.proto PiperOrigin-RevId: 449620845 Source-Link: googleapis/googleapis@117f86b Source-Link: googleapis/googleapis-gen@1d670db Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMWQ2NzBkYmIxYTlmZjE1NWNmNjg2ZTk1NDRmZWZmYjc1MDIxYTJmNSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: update protos to include InvalidateApprovalRequest and GetAccessApprovalServiceAccount APIs PiperOrigin-RevId: 449820922 Source-Link: googleapis/googleapis@9682584 Source-Link: googleapis/googleapis-gen@09360c9 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMDkzNjBjOTVjYTEyYWZmMDBiY2QyY2ZhMmY3NjE0YmJiM2UyOWJmMyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore: remove unused imports PiperOrigin-RevId: 450372109 Source-Link: googleapis/googleapis@942691f Source-Link: googleapis/googleapis-gen@609a369 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjA5YTM2OTY2YzQwZjcyNmZkMGRjNzFlOTUzZGM4M2Y4ZTUyZmVmMSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add latent_space_source to ExplanationMetadata in aiplatform v1 explanation_metadata.proto feat: add scaling to OnlineServingConfig in aiplatform v1 featurestore.proto feat: add template_metadata to PipelineJob in aiplatform v1 pipeline_job.proto PiperOrigin-RevId: 450687287 Source-Link: googleapis/googleapis@058bff3 Source-Link: googleapis/googleapis-gen@f072bfe Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZjA3MmJmZTc3MDRkOTk2YzQxZDc0YWMzYWExZDg1MTRmNDY0YzRmZiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add failure_policy to PipelineJob in aiplatform v1 & v1beta1 pipeline_job.proto PiperOrigin-RevId: 450704795 Source-Link: googleapis/googleapis@c875f2b Source-Link: googleapis/googleapis-gen@e606d62 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZTYwNmQ2MmFiMzJiODU0MzQ2OTc2NzhiMzAwNGYyMjA2ZDVjMDJhZSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add IAM policy to aiplatform_v1beta1.yaml feat: add preset configuration for example-based explanations in aiplatform v1beta1 explanation.proto feat: add latent_space_source to ExplanationMetadata in aiplatform v1beta1 explanation_metadata.proto feat: add successful_forecast_point_count to CompletionStats in completion_stats.proto PiperOrigin-RevId: 450727462 Source-Link: googleapis/googleapis@665682d Source-Link: googleapis/googleapis-gen@34cddbe Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMzRjZGRiZWYzOWMxN2M1OGY5NmY1ZmZlYmY2MDY1MTM2YjZkNTcxOSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore: use gapic-generator-python 1.0.0 PiperOrigin-RevId: 451250442 Source-Link: googleapis/googleapis@cca5e81 Source-Link: googleapis/googleapis-gen@0b219da Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMGIyMTlkYTE2MWE4YmRjYzNjNmY3YjJlZmNkODIxMDUxODJhMzBjYSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: Client libraries for the Dataform API This is the first release of the Public Dataform API client libraries. PiperOrigin-RevId: 451825930 Source-Link: googleapis/googleapis@34c6901 Source-Link: googleapis/googleapis-gen@68f6624 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjhmNjYyNDgyOTdhMjJiNmJlYjY0Njc3ZDEyNmFkMDAwNDczMmU1NyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: gcf-merge-on-green[bot] <60162190+gcf-merge-on-green[bot]@users.noreply.github.com> Co-authored-by: Yu-Han Liu <[email protected]>
1 parent 15fe100 commit b6bf6dc

File tree

75 files changed

+1724
-79
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

75 files changed

+1724
-79
lines changed

‎docs/definition_v1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1 Schema Trainingjob Definition v1 API
2+
=========================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1.schema.trainingjob.definition_v1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/definition_v1beta1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1beta1 Schema Trainingjob Definition v1beta1 API
2+
===================================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1beta1.schema.trainingjob.definition_v1beta1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/instance_v1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1 Schema Predict Instance v1 API
2+
===================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1.schema.predict.instance_v1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/instance_v1beta1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1beta1 Schema Predict Instance v1beta1 API
2+
=============================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1beta1.schema.predict.instance_v1beta1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/params_v1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1 Schema Predict Params v1 API
2+
=================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1.schema.predict.params_v1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/params_v1beta1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1beta1 Schema Predict Params v1beta1 API
2+
===========================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1beta1.schema.predict.params_v1beta1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/prediction_v1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1 Schema Predict Prediction v1 API
2+
=====================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1.schema.predict.prediction_v1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎docs/prediction_v1beta1/types.rst

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Types for Google Cloud Aiplatform V1beta1 Schema Predict Prediction v1beta1 API
2+
===============================================================================
3+
4+
.. automodule:: google.cloud.aiplatform.v1beta1.schema.predict.prediction_v1beta1.types
5+
:members:
6+
:undoc-members:
7+
:show-inheritance:

‎google/cloud/aiplatform_v1/__init__.py

+4
Original file line numberDiff line numberDiff line change
@@ -362,10 +362,12 @@
362362
from .types.model_service import UploadModelResponse
363363
from .types.operation import DeleteOperationMetadata
364364
from .types.operation import GenericOperationMetadata
365+
from .types.pipeline_failure_policy import PipelineFailurePolicy
365366
from .types.pipeline_job import PipelineJob
366367
from .types.pipeline_job import PipelineJobDetail
367368
from .types.pipeline_job import PipelineTaskDetail
368369
from .types.pipeline_job import PipelineTaskExecutorDetail
370+
from .types.pipeline_job import PipelineTemplateMetadata
369371
from .types.pipeline_service import CancelPipelineJobRequest
370372
from .types.pipeline_service import CancelTrainingPipelineRequest
371373
from .types.pipeline_service import CreatePipelineJobRequest
@@ -829,12 +831,14 @@
829831
"NearestNeighborSearchOperationMetadata",
830832
"NfsMount",
831833
"PauseModelDeploymentMonitoringJobRequest",
834+
"PipelineFailurePolicy",
832835
"PipelineJob",
833836
"PipelineJobDetail",
834837
"PipelineServiceClient",
835838
"PipelineState",
836839
"PipelineTaskDetail",
837840
"PipelineTaskExecutorDetail",
841+
"PipelineTemplateMetadata",
838842
"Port",
839843
"PredefinedSplit",
840844
"PredictRequest",

‎google/cloud/aiplatform_v1/services/migration_service/client.py

+9-9
Original file line numberDiff line numberDiff line change
@@ -192,40 +192,40 @@ def parse_annotated_dataset_path(path: str) -> Dict[str, str]:
192192
@staticmethod
193193
def dataset_path(
194194
project: str,
195+
location: str,
195196
dataset: str,
196197
) -> str:
197198
"""Returns a fully-qualified dataset string."""
198-
return "projects/{project}/datasets/{dataset}".format(
199+
return "projects/{project}/locations/{location}/datasets/{dataset}".format(
199200
project=project,
201+
location=location,
200202
dataset=dataset,
201203
)
202204

203205
@staticmethod
204206
def parse_dataset_path(path: str) -> Dict[str, str]:
205207
"""Parses a dataset path into its component segments."""
206-
m = re.match(r"^projects/(?P<project>.+?)/datasets/(?P<dataset>.+?)$", path)
208+
m = re.match(
209+
r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/datasets/(?P<dataset>.+?)$",
210+
path,
211+
)
207212
return m.groupdict() if m else {}
208213

209214
@staticmethod
210215
def dataset_path(
211216
project: str,
212-
location: str,
213217
dataset: str,
214218
) -> str:
215219
"""Returns a fully-qualified dataset string."""
216-
return "projects/{project}/locations/{location}/datasets/{dataset}".format(
220+
return "projects/{project}/datasets/{dataset}".format(
217221
project=project,
218-
location=location,
219222
dataset=dataset,
220223
)
221224

222225
@staticmethod
223226
def parse_dataset_path(path: str) -> Dict[str, str]:
224227
"""Parses a dataset path into its component segments."""
225-
m = re.match(
226-
r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/datasets/(?P<dataset>.+?)$",
227-
path,
228-
)
228+
m = re.match(r"^projects/(?P<project>.+?)/datasets/(?P<dataset>.+?)$", path)
229229
return m.groupdict() if m else {}
230230

231231
@staticmethod

‎google/cloud/aiplatform_v1/types/__init__.py

+3
Original file line numberDiff line numberDiff line change
@@ -423,6 +423,7 @@
423423
PipelineJobDetail,
424424
PipelineTaskDetail,
425425
PipelineTaskExecutorDetail,
426+
PipelineTemplateMetadata,
426427
)
427428
from .pipeline_service import (
428429
CancelPipelineJobRequest,
@@ -883,10 +884,12 @@
883884
"UploadModelResponse",
884885
"DeleteOperationMetadata",
885886
"GenericOperationMetadata",
887+
"PipelineFailurePolicy",
886888
"PipelineJob",
887889
"PipelineJobDetail",
888890
"PipelineTaskDetail",
889891
"PipelineTaskExecutorDetail",
892+
"PipelineTemplateMetadata",
890893
"CancelPipelineJobRequest",
891894
"CancelTrainingPipelineRequest",
892895
"CreatePipelineJobRequest",

‎google/cloud/aiplatform_v1/types/endpoint.py

+4-4
Original file line numberDiff line numberDiff line change
@@ -221,10 +221,10 @@ class DeployedModel(proto.Message):
221221
This value should be 1-10 characters, and valid characters
222222
are /[0-9]/.
223223
model (str):
224-
Required. The name of the Model that this is
225-
the deployment of. Note that the Model may be in
226-
a different location than the DeployedModel's
227-
Endpoint.
224+
Required. The resource name of the Model that
225+
this is the deployment of. Note that the Model
226+
may be in a different location than the
227+
DeployedModel's Endpoint.
228228
display_name (str):
229229
The display name of the DeployedModel. If not provided upon
230230
creation, the Model's display_name is used.

‎google/cloud/aiplatform_v1/types/explanation_metadata.py

+7
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,9 @@ class ExplanationMetadata(proto.Message):
6969
including the URI scheme, than the one given on input. The
7070
output URI will point to a location where the user only has
7171
a read access.
72+
latent_space_source (str):
73+
Name of the source to generate embeddings for
74+
example based explanations.
7275
"""
7376

7477
class InputMetadata(proto.Message):
@@ -457,6 +460,10 @@ class OutputMetadata(proto.Message):
457460
proto.STRING,
458461
number=3,
459462
)
463+
latent_space_source = proto.Field(
464+
proto.STRING,
465+
number=5,
466+
)
460467

461468

462469
__all__ = tuple(sorted(__protobuf__.manifest))

‎google/cloud/aiplatform_v1/types/featurestore.py

+34
Original file line numberDiff line numberDiff line change
@@ -92,12 +92,46 @@ class OnlineServingConfig(proto.Message):
9292
set to 0, the featurestore will not have an
9393
online store and cannot be used for online
9494
serving.
95+
scaling (google.cloud.aiplatform_v1.types.Featurestore.OnlineServingConfig.Scaling):
96+
Online serving scaling configuration. Only one of
97+
``fixed_node_count`` and ``scaling`` can be set. Setting one
98+
will reset the other.
9599
"""
96100

101+
class Scaling(proto.Message):
102+
r"""Online serving scaling configuration. If min_node_count and
103+
max_node_count are set to the same value, the cluster will be
104+
configured with the fixed number of node (no auto-scaling).
105+
106+
Attributes:
107+
min_node_count (int):
108+
Required. The minimum number of nodes to
109+
scale down to. Must be greater than or equal to
110+
1.
111+
max_node_count (int):
112+
The maximum number of nodes to scale up to. Must be greater
113+
than min_node_count, and less than or equal to 10 times of
114+
'min_node_count'.
115+
"""
116+
117+
min_node_count = proto.Field(
118+
proto.INT32,
119+
number=1,
120+
)
121+
max_node_count = proto.Field(
122+
proto.INT32,
123+
number=2,
124+
)
125+
97126
fixed_node_count = proto.Field(
98127
proto.INT32,
99128
number=2,
100129
)
130+
scaling = proto.Field(
131+
proto.MESSAGE,
132+
number=4,
133+
message="Featurestore.OnlineServingConfig.Scaling",
134+
)
101135

102136
name = proto.Field(
103137
proto.STRING,

‎google/cloud/aiplatform_v1/types/featurestore_online_service.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ class StreamingReadFeatureValuesRequest(proto.Message):
236236

237237
class FeatureValue(proto.Message):
238238
r"""Value for a feature.
239-
NEXT ID: 15
239+
(-- NEXT ID: 15 --)
240240
241241
This message has `oneof`_ fields (mutually exclusive fields).
242242
For each oneof, at most one member field can be set at the same time.

‎google/cloud/aiplatform_v1/types/manual_batch_tuning_parameters.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ class ManualBatchTuningParameters(proto.Message):
3838
value will result in a whole batch not fitting
3939
in a machine's memory, and the whole operation
4040
will fail.
41-
The default value is 4.
41+
The default value is 64.
4242
"""
4343

4444
batch_size = proto.Field(

‎google/cloud/aiplatform_v1/types/model_evaluation.py

+16
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@ class ModelEvaluation(proto.Message):
3737
name (str):
3838
Output only. The resource name of the
3939
ModelEvaluation.
40+
display_name (str):
41+
The display name of the ModelEvaluation.
4042
metrics_schema_uri (str):
4143
Points to a YAML file stored on Google Cloud Storage
4244
describing the
@@ -92,6 +94,11 @@ class ModelEvaluation(proto.Message):
9294
[ExplanationSpec][google.cloud.aiplatform.v1.ExplanationSpec]
9395
that are used for explaining the predicted values on the
9496
evaluated data.
97+
metadata (google.protobuf.struct_pb2.Value):
98+
The metadata of the ModelEvaluation. For the ModelEvaluation
99+
uploaded from Managed Pipeline, metadata contains a
100+
structured value with keys of "pipeline_job_id",
101+
"evaluation_dataset_type", "evaluation_dataset_path".
95102
"""
96103

97104
class ModelEvaluationExplanationSpec(proto.Message):
@@ -123,6 +130,10 @@ class ModelEvaluationExplanationSpec(proto.Message):
123130
proto.STRING,
124131
number=1,
125132
)
133+
display_name = proto.Field(
134+
proto.STRING,
135+
number=10,
136+
)
126137
metrics_schema_uri = proto.Field(
127138
proto.STRING,
128139
number=2,
@@ -159,6 +170,11 @@ class ModelEvaluationExplanationSpec(proto.Message):
159170
number=9,
160171
message=ModelEvaluationExplanationSpec,
161172
)
173+
metadata = proto.Field(
174+
proto.MESSAGE,
175+
number=11,
176+
message=struct_pb2.Value,
177+
)
162178

163179

164180
__all__ = tuple(sorted(__protobuf__.manifest))

‎google/cloud/aiplatform_v1/types/model_monitoring.py

+2
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,8 @@ class TrainingDataset(proto.Message):
8484
8585
"csv"
8686
The source file is a CSV file.
87+
"jsonl"
88+
The source file is a JSONL file.
8789
target_field (str):
8890
The target field name the model is to
8991
predict. This field will be excluded when doing

‎google/cloud/aiplatform_v1/types/pipeline_failure_policy.py

+41
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
# -*- coding: utf-8 -*-
2+
# Copyright 2022 Google LLC
3+
#
4+
# Licensed under the Apache License, Version 2.0 (the "License");
5+
# you may not use this file except in compliance with the License.
6+
# You may obtain a copy of the License at
7+
#
8+
# http://www.apache.org/licenses/LICENSE-2.0
9+
#
10+
# Unless required by applicable law or agreed to in writing, software
11+
# distributed under the License is distributed on an "AS IS" BASIS,
12+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
# See the License for the specific language governing permissions and
14+
# limitations under the License.
15+
#
16+
import proto # type: ignore
17+
18+
19+
__protobuf__ = proto.module(
20+
package="google.cloud.aiplatform.v1",
21+
manifest={
22+
"PipelineFailurePolicy",
23+
},
24+
)
25+
26+
27+
class PipelineFailurePolicy(proto.Enum):
28+
r"""Represents the failure policy of a pipeline. Currently, the default
29+
of a pipeline is that the pipeline will continue to run until no
30+
more tasks can be executed, also known as
31+
PIPELINE_FAILURE_POLICY_FAIL_SLOW. However, if a pipeline is set to
32+
PIPELINE_FAILURE_POLICY_FAIL_FAST, it will stop scheduling any new
33+
tasks when a task has failed. Any scheduled tasks will continue to
34+
completion.
35+
"""
36+
PIPELINE_FAILURE_POLICY_UNSPECIFIED = 0
37+
PIPELINE_FAILURE_POLICY_FAIL_SLOW = 1
38+
PIPELINE_FAILURE_POLICY_FAIL_FAST = 2
39+
40+
41+
__all__ = tuple(sorted(__protobuf__.manifest))

0 commit comments

Comments
 (0)