From 15b89b01311ae9741ab6580a516218d4745d7e5e Mon Sep 17 00:00:00 2001 From: ddalvi Date: Wed, 30 Oct 2024 12:30:58 -0400 Subject: [PATCH] feat(sdk+api) Implement Semaphores and Mutexes Pipeline Configuration Signed-off-by: ddalvi --- .../go/pipelinespec/pipeline_spec.pb.go | 1602 ++++------------- api/v2alpha1/pipeline_spec.proto | 6 +- .../kfp/compiler/pipeline_spec_builder.py | 10 +- sdk/python/kfp/dsl/pipeline_config.py | 23 +- 4 files changed, 351 insertions(+), 1290 deletions(-) diff --git a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go index b4bca0cec5f..bbac8b7fc92 100644 --- a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go +++ b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v3.17.3 +// protoc-gen-go v1.35.1 +// protoc v4.25.3 // source: pipeline_spec.proto package pipelinespec @@ -338,11 +338,9 @@ type PipelineJob struct { func (x *PipelineJob) Reset() { *x = PipelineJob{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineJob) String() string { @@ -353,7 +351,7 @@ func (*PipelineJob) ProtoMessage() {} func (x *PipelineJob) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -429,11 +427,9 @@ type PipelineSpec struct { func (x *PipelineSpec) Reset() { *x = PipelineSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineSpec) String() string { @@ -444,7 +440,7 @@ func (*PipelineSpec) ProtoMessage() {} func (x *PipelineSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -531,11 +527,9 @@ type ComponentSpec struct { func (x *ComponentSpec) Reset() { *x = ComponentSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentSpec) String() string { @@ -546,7 +540,7 @@ func (*ComponentSpec) ProtoMessage() {} func (x *ComponentSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[2] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -633,11 +627,9 @@ type DagSpec struct { func (x *DagSpec) Reset() { *x = DagSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[3] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagSpec) String() string { @@ -648,7 +640,7 @@ func (*DagSpec) ProtoMessage() {} func (x *DagSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[3] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -691,11 +683,9 @@ type DagOutputsSpec struct { func (x *DagOutputsSpec) Reset() { *x = DagOutputsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[4] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec) String() string { @@ -706,7 +696,7 @@ func (*DagOutputsSpec) ProtoMessage() {} func (x *DagOutputsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[4] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -749,11 +739,9 @@ type ComponentInputsSpec struct { func (x *ComponentInputsSpec) Reset() { *x = ComponentInputsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentInputsSpec) String() string { @@ -764,7 +752,7 @@ func (*ComponentInputsSpec) ProtoMessage() {} func (x *ComponentInputsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[5] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -807,11 +795,9 @@ type ComponentOutputsSpec struct { func (x *ComponentOutputsSpec) Reset() { *x = ComponentOutputsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[6] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentOutputsSpec) String() string { @@ -822,7 +808,7 @@ func (*ComponentOutputsSpec) ProtoMessage() {} func (x *ComponentOutputsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[6] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -866,11 +852,9 @@ type TaskInputsSpec struct { func (x *TaskInputsSpec) Reset() { *x = TaskInputsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[7] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec) String() string { @@ -881,7 +865,7 @@ func (*TaskInputsSpec) ProtoMessage() {} func (x *TaskInputsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[7] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -931,11 +915,9 @@ type TaskOutputsSpec struct { func (x *TaskOutputsSpec) Reset() { *x = TaskOutputsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[8] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskOutputsSpec) String() string { @@ -946,7 +928,7 @@ func (*TaskOutputsSpec) ProtoMessage() {} func (x *TaskOutputsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[8] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -987,11 +969,9 @@ type PrimitiveType struct { func (x *PrimitiveType) Reset() { *x = PrimitiveType{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[9] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PrimitiveType) String() string { @@ -1002,7 +982,7 @@ func (*PrimitiveType) ProtoMessage() {} func (x *PrimitiveType) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[9] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1027,11 +1007,9 @@ type ParameterType struct { func (x *ParameterType) Reset() { *x = ParameterType{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ParameterType) String() string { @@ -1042,7 +1020,7 @@ func (*ParameterType) ProtoMessage() {} func (x *ParameterType) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[10] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1111,11 +1089,9 @@ type PipelineTaskSpec struct { func (x *PipelineTaskSpec) Reset() { *x = PipelineTaskSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskSpec) String() string { @@ -1126,7 +1102,7 @@ func (*PipelineTaskSpec) ProtoMessage() {} func (x *PipelineTaskSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[11] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1252,11 +1228,9 @@ type ArtifactIteratorSpec struct { func (x *ArtifactIteratorSpec) Reset() { *x = ArtifactIteratorSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ArtifactIteratorSpec) String() string { @@ -1267,7 +1241,7 @@ func (*ArtifactIteratorSpec) ProtoMessage() {} func (x *ArtifactIteratorSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[12] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1312,11 +1286,9 @@ type ParameterIteratorSpec struct { func (x *ParameterIteratorSpec) Reset() { *x = ParameterIteratorSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[13] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ParameterIteratorSpec) String() string { @@ -1327,7 +1299,7 @@ func (*ParameterIteratorSpec) ProtoMessage() {} func (x *ParameterIteratorSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[13] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1368,11 +1340,9 @@ type ComponentRef struct { func (x *ComponentRef) Reset() { *x = ComponentRef{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[14] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentRef) String() string { @@ -1383,7 +1353,7 @@ func (*ComponentRef) ProtoMessage() {} func (x *ComponentRef) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[14] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1424,11 +1394,9 @@ type PipelineInfo struct { func (x *PipelineInfo) Reset() { *x = PipelineInfo{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[15] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineInfo) String() string { @@ -1439,7 +1407,7 @@ func (*PipelineInfo) ProtoMessage() {} func (x *PipelineInfo) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[15] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1494,11 +1462,9 @@ type ArtifactTypeSchema struct { func (x *ArtifactTypeSchema) Reset() { *x = ArtifactTypeSchema{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[16] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ArtifactTypeSchema) String() string { @@ -1509,7 +1475,7 @@ func (*ArtifactTypeSchema) ProtoMessage() {} func (x *ArtifactTypeSchema) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[16] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1609,11 +1575,9 @@ type PipelineTaskInfo struct { func (x *PipelineTaskInfo) Reset() { *x = PipelineTaskInfo{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[17] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskInfo) String() string { @@ -1624,7 +1588,7 @@ func (*PipelineTaskInfo) ProtoMessage() {} func (x *PipelineTaskInfo) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[17] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1665,11 +1629,9 @@ type ValueOrRuntimeParameter struct { func (x *ValueOrRuntimeParameter) Reset() { *x = ValueOrRuntimeParameter{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[18] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ValueOrRuntimeParameter) String() string { @@ -1680,7 +1642,7 @@ func (*ValueOrRuntimeParameter) ProtoMessage() {} func (x *ValueOrRuntimeParameter) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[18] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1765,11 +1727,9 @@ type PipelineDeploymentConfig struct { func (x *PipelineDeploymentConfig) Reset() { *x = PipelineDeploymentConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[19] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[19] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig) String() string { @@ -1780,7 +1740,7 @@ func (*PipelineDeploymentConfig) ProtoMessage() {} func (x *PipelineDeploymentConfig) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[19] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1818,11 +1778,9 @@ type Value struct { func (x *Value) Reset() { *x = Value{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[20] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[20] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *Value) String() string { @@ -1833,7 +1791,7 @@ func (*Value) ProtoMessage() {} func (x *Value) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[20] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1929,11 +1887,9 @@ type RuntimeArtifact struct { func (x *RuntimeArtifact) Reset() { *x = RuntimeArtifact{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[21] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[21] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *RuntimeArtifact) String() string { @@ -1944,7 +1900,7 @@ func (*RuntimeArtifact) ProtoMessage() {} func (x *RuntimeArtifact) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[21] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2015,11 +1971,9 @@ type ArtifactList struct { func (x *ArtifactList) Reset() { *x = ArtifactList{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[22] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[22] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ArtifactList) String() string { @@ -2030,7 +1984,7 @@ func (*ArtifactList) ProtoMessage() {} func (x *ArtifactList) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[22] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2090,11 +2044,9 @@ type ExecutorInput struct { func (x *ExecutorInput) Reset() { *x = ExecutorInput{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[23] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[23] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ExecutorInput) String() string { @@ -2105,7 +2057,7 @@ func (*ExecutorInput) ProtoMessage() {} func (x *ExecutorInput) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[23] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2154,11 +2106,9 @@ type ExecutorOutput struct { func (x *ExecutorOutput) Reset() { *x = ExecutorOutput{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[24] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[24] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ExecutorOutput) String() string { @@ -2169,7 +2119,7 @@ func (*ExecutorOutput) ProtoMessage() {} func (x *ExecutorOutput) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[24] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2235,11 +2185,9 @@ type PipelineTaskFinalStatus struct { func (x *PipelineTaskFinalStatus) Reset() { *x = PipelineTaskFinalStatus{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[25] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[25] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskFinalStatus) String() string { @@ -2250,7 +2198,7 @@ func (*PipelineTaskFinalStatus) ProtoMessage() {} func (x *PipelineTaskFinalStatus) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[25] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2317,11 +2265,9 @@ type PipelineStateEnum struct { func (x *PipelineStateEnum) Reset() { *x = PipelineStateEnum{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[26] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[26] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineStateEnum) String() string { @@ -2332,7 +2278,7 @@ func (*PipelineStateEnum) ProtoMessage() {} func (x *PipelineStateEnum) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[26] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2359,11 +2305,9 @@ type PlatformSpec struct { func (x *PlatformSpec) Reset() { *x = PlatformSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[27] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[27] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PlatformSpec) String() string { @@ -2374,7 +2318,7 @@ func (*PlatformSpec) ProtoMessage() {} func (x *PlatformSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[27] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2413,11 +2357,9 @@ type SinglePlatformSpec struct { func (x *SinglePlatformSpec) Reset() { *x = SinglePlatformSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[28] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[28] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *SinglePlatformSpec) String() string { @@ -2428,7 +2370,7 @@ func (*SinglePlatformSpec) ProtoMessage() {} func (x *SinglePlatformSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[28] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2483,11 +2425,9 @@ type PlatformDeploymentConfig struct { func (x *PlatformDeploymentConfig) Reset() { *x = PlatformDeploymentConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[29] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[29] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PlatformDeploymentConfig) String() string { @@ -2498,7 +2438,7 @@ func (*PlatformDeploymentConfig) ProtoMessage() {} func (x *PlatformDeploymentConfig) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[29] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2525,15 +2465,16 @@ type PipelineConfig struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields + + SemaphoreName string `protobuf:"bytes,1,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"` + MutexName string `protobuf:"bytes,2,opt,name=mutex_name,json=mutexName,proto3" json:"mutex_name,omitempty"` } func (x *PipelineConfig) Reset() { *x = PipelineConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[30] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[30] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineConfig) String() string { @@ -2544,7 +2485,7 @@ func (*PipelineConfig) ProtoMessage() {} func (x *PipelineConfig) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[30] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2559,6 +2500,20 @@ func (*PipelineConfig) Descriptor() ([]byte, []int) { return file_pipeline_spec_proto_rawDescGZIP(), []int{30} } +func (x *PipelineConfig) GetSemaphoreName() string { + if x != nil { + return x.SemaphoreName + } + return "" +} + +func (x *PipelineConfig) GetMutexName() string { + if x != nil { + return x.MutexName + } + return "" +} + // The runtime config of a PipelineJob. type PipelineJob_RuntimeConfig struct { state protoimpl.MessageState @@ -2582,11 +2537,9 @@ type PipelineJob_RuntimeConfig struct { func (x *PipelineJob_RuntimeConfig) Reset() { *x = PipelineJob_RuntimeConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[32] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[32] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineJob_RuntimeConfig) String() string { @@ -2597,7 +2550,7 @@ func (*PipelineJob_RuntimeConfig) ProtoMessage() {} func (x *PipelineJob_RuntimeConfig) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[32] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2650,11 +2603,9 @@ type PipelineSpec_RuntimeParameter struct { func (x *PipelineSpec_RuntimeParameter) Reset() { *x = PipelineSpec_RuntimeParameter{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[35] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[35] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineSpec_RuntimeParameter) String() string { @@ -2665,7 +2616,7 @@ func (*PipelineSpec_RuntimeParameter) ProtoMessage() {} func (x *PipelineSpec_RuntimeParameter) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[35] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2709,11 +2660,9 @@ type DagOutputsSpec_ArtifactSelectorSpec struct { func (x *DagOutputsSpec_ArtifactSelectorSpec) Reset() { *x = DagOutputsSpec_ArtifactSelectorSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[38] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[38] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_ArtifactSelectorSpec) String() string { @@ -2724,7 +2673,7 @@ func (*DagOutputsSpec_ArtifactSelectorSpec) ProtoMessage() {} func (x *DagOutputsSpec_ArtifactSelectorSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[38] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2767,11 +2716,9 @@ type DagOutputsSpec_DagOutputArtifactSpec struct { func (x *DagOutputsSpec_DagOutputArtifactSpec) Reset() { *x = DagOutputsSpec_DagOutputArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[39] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[39] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_DagOutputArtifactSpec) String() string { @@ -2782,7 +2729,7 @@ func (*DagOutputsSpec_DagOutputArtifactSpec) ProtoMessage() {} func (x *DagOutputsSpec_DagOutputArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[39] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2819,11 +2766,9 @@ type DagOutputsSpec_ParameterSelectorSpec struct { func (x *DagOutputsSpec_ParameterSelectorSpec) Reset() { *x = DagOutputsSpec_ParameterSelectorSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[41] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[41] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_ParameterSelectorSpec) String() string { @@ -2834,7 +2779,7 @@ func (*DagOutputsSpec_ParameterSelectorSpec) ProtoMessage() {} func (x *DagOutputsSpec_ParameterSelectorSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[41] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2874,11 +2819,9 @@ type DagOutputsSpec_ParameterSelectorsSpec struct { func (x *DagOutputsSpec_ParameterSelectorsSpec) Reset() { *x = DagOutputsSpec_ParameterSelectorsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[42] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[42] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_ParameterSelectorsSpec) String() string { @@ -2889,7 +2832,7 @@ func (*DagOutputsSpec_ParameterSelectorsSpec) ProtoMessage() {} func (x *DagOutputsSpec_ParameterSelectorsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[42] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2922,11 +2865,9 @@ type DagOutputsSpec_MapParameterSelectorsSpec struct { func (x *DagOutputsSpec_MapParameterSelectorsSpec) Reset() { *x = DagOutputsSpec_MapParameterSelectorsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[43] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[43] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_MapParameterSelectorsSpec) String() string { @@ -2937,7 +2878,7 @@ func (*DagOutputsSpec_MapParameterSelectorsSpec) ProtoMessage() {} func (x *DagOutputsSpec_MapParameterSelectorsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[43] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -2980,11 +2921,9 @@ type DagOutputsSpec_DagOutputParameterSpec struct { func (x *DagOutputsSpec_DagOutputParameterSpec) Reset() { *x = DagOutputsSpec_DagOutputParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[44] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[44] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DagOutputsSpec_DagOutputParameterSpec) String() string { @@ -2995,7 +2934,7 @@ func (*DagOutputsSpec_DagOutputParameterSpec) ProtoMessage() {} func (x *DagOutputsSpec_DagOutputParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[44] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3078,11 +3017,9 @@ type ComponentInputsSpec_ArtifactSpec struct { func (x *ComponentInputsSpec_ArtifactSpec) Reset() { *x = ComponentInputsSpec_ArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[47] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[47] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentInputsSpec_ArtifactSpec) String() string { @@ -3093,7 +3030,7 @@ func (*ComponentInputsSpec_ArtifactSpec) ProtoMessage() {} func (x *ComponentInputsSpec_ArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[47] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3168,11 +3105,9 @@ type ComponentInputsSpec_ParameterSpec struct { func (x *ComponentInputsSpec_ParameterSpec) Reset() { *x = ComponentInputsSpec_ParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[48] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[48] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentInputsSpec_ParameterSpec) String() string { @@ -3183,7 +3118,7 @@ func (*ComponentInputsSpec_ParameterSpec) ProtoMessage() {} func (x *ComponentInputsSpec_ParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[48] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3260,11 +3195,9 @@ type ComponentOutputsSpec_ArtifactSpec struct { func (x *ComponentOutputsSpec_ArtifactSpec) Reset() { *x = ComponentOutputsSpec_ArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[51] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[51] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentOutputsSpec_ArtifactSpec) String() string { @@ -3275,7 +3208,7 @@ func (*ComponentOutputsSpec_ArtifactSpec) ProtoMessage() {} func (x *ComponentOutputsSpec_ArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[51] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3354,11 +3287,9 @@ type ComponentOutputsSpec_ParameterSpec struct { func (x *ComponentOutputsSpec_ParameterSpec) Reset() { *x = ComponentOutputsSpec_ParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[52] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[52] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ComponentOutputsSpec_ParameterSpec) String() string { @@ -3369,7 +3300,7 @@ func (*ComponentOutputsSpec_ParameterSpec) ProtoMessage() {} func (x *ComponentOutputsSpec_ParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[52] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3421,11 +3352,9 @@ type TaskInputsSpec_InputArtifactSpec struct { func (x *TaskInputsSpec_InputArtifactSpec) Reset() { *x = TaskInputsSpec_InputArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[57] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[57] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec_InputArtifactSpec) String() string { @@ -3436,7 +3365,7 @@ func (*TaskInputsSpec_InputArtifactSpec) ProtoMessage() {} func (x *TaskInputsSpec_InputArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[57] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3539,11 +3468,9 @@ type TaskInputsSpec_InputParameterSpec struct { func (x *TaskInputsSpec_InputParameterSpec) Reset() { *x = TaskInputsSpec_InputParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[58] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[58] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec_InputParameterSpec) String() string { @@ -3554,7 +3481,7 @@ func (*TaskInputsSpec_InputParameterSpec) ProtoMessage() {} func (x *TaskInputsSpec_InputParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[58] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3660,11 +3587,9 @@ type TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec struct { func (x *TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec) Reset() { *x = TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[61] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[61] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec) String() string { @@ -3675,7 +3600,7 @@ func (*TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec) ProtoMessage() { func (x *TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[61] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3719,11 +3644,9 @@ type TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec struct { func (x *TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec) Reset() { *x = TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[62] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[62] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec) String() string { @@ -3734,7 +3657,7 @@ func (*TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec) ProtoMessage() func (x *TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[62] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3777,11 +3700,9 @@ type TaskInputsSpec_InputParameterSpec_TaskFinalStatus struct { func (x *TaskInputsSpec_InputParameterSpec_TaskFinalStatus) Reset() { *x = TaskInputsSpec_InputParameterSpec_TaskFinalStatus{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[63] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[63] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskInputsSpec_InputParameterSpec_TaskFinalStatus) String() string { @@ -3792,7 +3713,7 @@ func (*TaskInputsSpec_InputParameterSpec_TaskFinalStatus) ProtoMessage() {} func (x *TaskInputsSpec_InputParameterSpec_TaskFinalStatus) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[63] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3832,11 +3753,9 @@ type TaskOutputsSpec_OutputArtifactSpec struct { func (x *TaskOutputsSpec_OutputArtifactSpec) Reset() { *x = TaskOutputsSpec_OutputArtifactSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[64] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[64] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskOutputsSpec_OutputArtifactSpec) String() string { @@ -3847,7 +3766,7 @@ func (*TaskOutputsSpec_OutputArtifactSpec) ProtoMessage() {} func (x *TaskOutputsSpec_OutputArtifactSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[64] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3895,11 +3814,9 @@ type TaskOutputsSpec_OutputParameterSpec struct { func (x *TaskOutputsSpec_OutputParameterSpec) Reset() { *x = TaskOutputsSpec_OutputParameterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[65] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[65] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *TaskOutputsSpec_OutputParameterSpec) String() string { @@ -3910,7 +3827,7 @@ func (*TaskOutputsSpec_OutputParameterSpec) ProtoMessage() {} func (x *TaskOutputsSpec_OutputParameterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[65] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -3943,11 +3860,9 @@ type PipelineTaskSpec_CachingOptions struct { func (x *PipelineTaskSpec_CachingOptions) Reset() { *x = PipelineTaskSpec_CachingOptions{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[70] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[70] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskSpec_CachingOptions) String() string { @@ -3958,7 +3873,7 @@ func (*PipelineTaskSpec_CachingOptions) ProtoMessage() {} func (x *PipelineTaskSpec_CachingOptions) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[70] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4005,11 +3920,9 @@ type PipelineTaskSpec_TriggerPolicy struct { func (x *PipelineTaskSpec_TriggerPolicy) Reset() { *x = PipelineTaskSpec_TriggerPolicy{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[71] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[71] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskSpec_TriggerPolicy) String() string { @@ -4020,7 +3933,7 @@ func (*PipelineTaskSpec_TriggerPolicy) ProtoMessage() {} func (x *PipelineTaskSpec_TriggerPolicy) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[71] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4071,11 +3984,9 @@ type PipelineTaskSpec_RetryPolicy struct { func (x *PipelineTaskSpec_RetryPolicy) Reset() { *x = PipelineTaskSpec_RetryPolicy{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[72] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[72] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskSpec_RetryPolicy) String() string { @@ -4086,7 +3997,7 @@ func (*PipelineTaskSpec_RetryPolicy) ProtoMessage() {} func (x *PipelineTaskSpec_RetryPolicy) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[72] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4143,11 +4054,9 @@ type PipelineTaskSpec_IteratorPolicy struct { func (x *PipelineTaskSpec_IteratorPolicy) Reset() { *x = PipelineTaskSpec_IteratorPolicy{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[73] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[73] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineTaskSpec_IteratorPolicy) String() string { @@ -4158,7 +4067,7 @@ func (*PipelineTaskSpec_IteratorPolicy) ProtoMessage() {} func (x *PipelineTaskSpec_IteratorPolicy) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[73] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4195,11 +4104,9 @@ type ArtifactIteratorSpec_ItemsSpec struct { func (x *ArtifactIteratorSpec_ItemsSpec) Reset() { *x = ArtifactIteratorSpec_ItemsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[74] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[74] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ArtifactIteratorSpec_ItemsSpec) String() string { @@ -4210,7 +4117,7 @@ func (*ArtifactIteratorSpec_ItemsSpec) ProtoMessage() {} func (x *ArtifactIteratorSpec_ItemsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[74] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4251,11 +4158,9 @@ type ParameterIteratorSpec_ItemsSpec struct { func (x *ParameterIteratorSpec_ItemsSpec) Reset() { *x = ParameterIteratorSpec_ItemsSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[75] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[75] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ParameterIteratorSpec_ItemsSpec) String() string { @@ -4266,7 +4171,7 @@ func (*ParameterIteratorSpec_ItemsSpec) ProtoMessage() {} func (x *ParameterIteratorSpec_ItemsSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[75] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4347,11 +4252,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec struct { func (x *PipelineDeploymentConfig_PipelineContainerSpec) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[76] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[76] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec) String() string { @@ -4362,7 +4265,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec) ProtoMessage() {} func (x *PipelineDeploymentConfig_PipelineContainerSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[76] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4447,11 +4350,9 @@ type PipelineDeploymentConfig_ImporterSpec struct { func (x *PipelineDeploymentConfig_ImporterSpec) Reset() { *x = PipelineDeploymentConfig_ImporterSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[77] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[77] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_ImporterSpec) String() string { @@ -4462,7 +4363,7 @@ func (*PipelineDeploymentConfig_ImporterSpec) ProtoMessage() {} func (x *PipelineDeploymentConfig_ImporterSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[77] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4538,11 +4439,9 @@ type PipelineDeploymentConfig_ResolverSpec struct { func (x *PipelineDeploymentConfig_ResolverSpec) Reset() { *x = PipelineDeploymentConfig_ResolverSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[78] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[78] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_ResolverSpec) String() string { @@ -4553,7 +4452,7 @@ func (*PipelineDeploymentConfig_ResolverSpec) ProtoMessage() {} func (x *PipelineDeploymentConfig_ResolverSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[78] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4594,11 +4493,9 @@ type PipelineDeploymentConfig_AIPlatformCustomJobSpec struct { func (x *PipelineDeploymentConfig_AIPlatformCustomJobSpec) Reset() { *x = PipelineDeploymentConfig_AIPlatformCustomJobSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[79] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[79] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_AIPlatformCustomJobSpec) String() string { @@ -4609,7 +4506,7 @@ func (*PipelineDeploymentConfig_AIPlatformCustomJobSpec) ProtoMessage() {} func (x *PipelineDeploymentConfig_AIPlatformCustomJobSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[79] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4648,11 +4545,9 @@ type PipelineDeploymentConfig_ExecutorSpec struct { func (x *PipelineDeploymentConfig_ExecutorSpec) Reset() { *x = PipelineDeploymentConfig_ExecutorSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[80] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[80] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_ExecutorSpec) String() string { @@ -4663,7 +4558,7 @@ func (*PipelineDeploymentConfig_ExecutorSpec) ProtoMessage() {} func (x *PipelineDeploymentConfig_ExecutorSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[80] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4771,11 +4666,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle struct { func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[82] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[82] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle) String() string { @@ -4786,7 +4679,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle) ProtoMessage() func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[82] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4861,11 +4754,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec struct { func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[83] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[83] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec) String() string { @@ -4876,7 +4767,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec) ProtoMessage func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[83] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -4982,11 +4873,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec_EnvVar struct { func (x *PipelineDeploymentConfig_PipelineContainerSpec_EnvVar) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec_EnvVar{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[84] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[84] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec_EnvVar) String() string { @@ -4997,7 +4886,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec_EnvVar) ProtoMessage() {} func (x *PipelineDeploymentConfig_PipelineContainerSpec_EnvVar) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[84] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5040,11 +4929,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec struct { func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[85] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[85] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec) String() string { @@ -5055,7 +4942,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec) ProtoMessa func (x *PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[85] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5112,11 +4999,9 @@ type PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConf func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConfig) Reset() { *x = PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[86] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[86] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConfig) String() string { @@ -5128,7 +5013,7 @@ func (*PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorCo func (x *PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConfig) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[86] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5196,11 +5081,9 @@ type PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec struct { func (x *PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec) Reset() { *x = PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[89] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[89] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec) String() string { @@ -5211,7 +5094,7 @@ func (*PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec) ProtoMessage() { func (x *PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[89] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5259,11 +5142,9 @@ type ExecutorInput_Inputs struct { func (x *ExecutorInput_Inputs) Reset() { *x = ExecutorInput_Inputs{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[93] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[93] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ExecutorInput_Inputs) String() string { @@ -5274,7 +5155,7 @@ func (*ExecutorInput_Inputs) ProtoMessage() {} func (x *ExecutorInput_Inputs) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[93] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5324,11 +5205,9 @@ type ExecutorInput_OutputParameter struct { func (x *ExecutorInput_OutputParameter) Reset() { *x = ExecutorInput_OutputParameter{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[94] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[94] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ExecutorInput_OutputParameter) String() string { @@ -5339,7 +5218,7 @@ func (*ExecutorInput_OutputParameter) ProtoMessage() {} func (x *ExecutorInput_OutputParameter) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[94] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -5381,11 +5260,9 @@ type ExecutorInput_Outputs struct { func (x *ExecutorInput_Outputs) Reset() { *x = ExecutorInput_Outputs{} - if protoimpl.UnsafeEnabled { - mi := &file_pipeline_spec_proto_msgTypes[95] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pipeline_spec_proto_msgTypes[95] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ExecutorInput_Outputs) String() string { @@ -5396,7 +5273,7 @@ func (*ExecutorInput_Outputs) ProtoMessage() {} func (x *ExecutorInput_Outputs) ProtoReflect() protoreflect.Message { mi := &file_pipeline_spec_proto_msgTypes[95] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -6523,12 +6400,17 @@ var file_pipeline_spec_proto_rawDesc = []byte{ 0x6b, 0x65, 0x79, 0x12, 0x2d, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x05, 0x76, 0x61, 0x6c, - 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x10, 0x0a, 0x0e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, - 0x6e, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, - 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6b, 0x75, 0x62, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x2f, - 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, - 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, - 0x6e, 0x65, 0x73, 0x70, 0x65, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x56, 0x0a, 0x0e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, + 0x6e, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x65, 0x6d, 0x61, + 0x70, 0x68, 0x6f, 0x72, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x0d, 0x73, 0x65, 0x6d, 0x61, 0x70, 0x68, 0x6f, 0x72, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x1d, 0x0a, 0x0a, 0x6d, 0x75, 0x74, 0x65, 0x78, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x09, 0x6d, 0x75, 0x74, 0x65, 0x78, 0x4e, 0x61, 0x6d, 0x65, 0x42, 0x3c, + 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6b, 0x75, 0x62, + 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, + 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x67, 0x6f, 0x2f, + 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x70, 0x65, 0x63, 0x62, 0x06, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -6545,7 +6427,7 @@ func file_pipeline_spec_proto_rawDescGZIP() []byte { var file_pipeline_spec_proto_enumTypes = make([]protoimpl.EnumInfo, 4) var file_pipeline_spec_proto_msgTypes = make([]protoimpl.MessageInfo, 106) -var file_pipeline_spec_proto_goTypes = []interface{}{ +var file_pipeline_spec_proto_goTypes = []any{ (PrimitiveType_PrimitiveTypeEnum)(0), // 0: ml_pipelines.PrimitiveType.PrimitiveTypeEnum (ParameterType_ParameterTypeEnum)(0), // 1: ml_pipelines.ParameterType.ParameterTypeEnum (PipelineTaskSpec_TriggerPolicy_TriggerStrategy)(0), // 2: ml_pipelines.PipelineTaskSpec.TriggerPolicy.TriggerStrategy @@ -6813,890 +6695,48 @@ func file_pipeline_spec_proto_init() { if File_pipeline_spec_proto != nil { return } - if !protoimpl.UnsafeEnabled { - file_pipeline_spec_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineJob); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentInputsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentOutputsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskOutputsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PrimitiveType); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParameterType); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ArtifactIteratorSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParameterIteratorSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentRef); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineInfo); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ArtifactTypeSchema); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskInfo); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ValueOrRuntimeParameter); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Value); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*RuntimeArtifact); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ArtifactList); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ExecutorInput); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ExecutorOutput); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskFinalStatus); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineStateEnum); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PlatformSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SinglePlatformSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PlatformDeploymentConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineJob_RuntimeConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineSpec_RuntimeParameter); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_ArtifactSelectorSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_DagOutputArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_ParameterSelectorSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[42].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_ParameterSelectorsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[43].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_MapParameterSelectorsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[44].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DagOutputsSpec_DagOutputParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[47].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentInputsSpec_ArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentInputsSpec_ParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[51].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentOutputsSpec_ArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[52].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ComponentOutputsSpec_ParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[57].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec_InputArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[58].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec_InputParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[61].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec_InputArtifactSpec_TaskOutputArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[62].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec_InputParameterSpec_TaskOutputParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[63].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskInputsSpec_InputParameterSpec_TaskFinalStatus); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[64].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskOutputsSpec_OutputArtifactSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[65].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*TaskOutputsSpec_OutputParameterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[70].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskSpec_CachingOptions); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[71].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskSpec_TriggerPolicy); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[72].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskSpec_RetryPolicy); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[73].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineTaskSpec_IteratorPolicy); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[74].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ArtifactIteratorSpec_ItemsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[75].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParameterIteratorSpec_ItemsSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[76].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[77].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_ImporterSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[78].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_ResolverSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[79].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_AIPlatformCustomJobSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[80].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_ExecutorSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[82].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[83].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[84].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec_EnvVar); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[85].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec_Lifecycle_Exec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[86].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_PipelineContainerSpec_ResourceSpec_AcceleratorConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[89].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*PipelineDeploymentConfig_ResolverSpec_ArtifactQuerySpec); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[93].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ExecutorInput_Inputs); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[94].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ExecutorInput_OutputParameter); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pipeline_spec_proto_msgTypes[95].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ExecutorInput_Outputs); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - } - file_pipeline_spec_proto_msgTypes[2].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[2].OneofWrappers = []any{ (*ComponentSpec_Dag)(nil), (*ComponentSpec_ExecutorLabel)(nil), } - file_pipeline_spec_proto_msgTypes[11].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[11].OneofWrappers = []any{ (*PipelineTaskSpec_ArtifactIterator)(nil), (*PipelineTaskSpec_ParameterIterator)(nil), } - file_pipeline_spec_proto_msgTypes[16].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[16].OneofWrappers = []any{ (*ArtifactTypeSchema_SchemaTitle)(nil), (*ArtifactTypeSchema_SchemaUri)(nil), (*ArtifactTypeSchema_InstanceSchema)(nil), } - file_pipeline_spec_proto_msgTypes[18].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[18].OneofWrappers = []any{ (*ValueOrRuntimeParameter_ConstantValue)(nil), (*ValueOrRuntimeParameter_RuntimeParameter)(nil), (*ValueOrRuntimeParameter_Constant)(nil), } - file_pipeline_spec_proto_msgTypes[20].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[20].OneofWrappers = []any{ (*Value_IntValue)(nil), (*Value_DoubleValue)(nil), (*Value_StringValue)(nil), } - file_pipeline_spec_proto_msgTypes[44].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[44].OneofWrappers = []any{ (*DagOutputsSpec_DagOutputParameterSpec_ValueFromParameter)(nil), (*DagOutputsSpec_DagOutputParameterSpec_ValueFromOneof)(nil), } - file_pipeline_spec_proto_msgTypes[57].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[57].OneofWrappers = []any{ (*TaskInputsSpec_InputArtifactSpec_TaskOutputArtifact)(nil), (*TaskInputsSpec_InputArtifactSpec_ComponentInputArtifact)(nil), } - file_pipeline_spec_proto_msgTypes[58].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[58].OneofWrappers = []any{ (*TaskInputsSpec_InputParameterSpec_TaskOutputParameter)(nil), (*TaskInputsSpec_InputParameterSpec_RuntimeValue)(nil), (*TaskInputsSpec_InputParameterSpec_ComponentInputParameter)(nil), (*TaskInputsSpec_InputParameterSpec_TaskFinalStatus_)(nil), } - file_pipeline_spec_proto_msgTypes[75].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[75].OneofWrappers = []any{ (*ParameterIteratorSpec_ItemsSpec_Raw)(nil), (*ParameterIteratorSpec_ItemsSpec_InputParameter)(nil), } - file_pipeline_spec_proto_msgTypes[80].OneofWrappers = []interface{}{ + file_pipeline_spec_proto_msgTypes[80].OneofWrappers = []any{ (*PipelineDeploymentConfig_ExecutorSpec_Container)(nil), (*PipelineDeploymentConfig_ExecutorSpec_Importer)(nil), (*PipelineDeploymentConfig_ExecutorSpec_Resolver)(nil), diff --git a/api/v2alpha1/pipeline_spec.proto b/api/v2alpha1/pipeline_spec.proto index 075913f8052..f0f687a9c9e 100644 --- a/api/v2alpha1/pipeline_spec.proto +++ b/api/v2alpha1/pipeline_spec.proto @@ -1103,5 +1103,9 @@ message PlatformDeploymentConfig { // Spec for pipeline-level config options. See PipelineConfig DSL class. message PipelineConfig { - // TODO add pipeline-level configs + // Name of the semaphore to control pipeline concurrency + string semaphore_name = 1; + + // Name of the mutex to ensure mutual exclusion + string mutex_name = 2; } diff --git a/sdk/python/kfp/compiler/pipeline_spec_builder.py b/sdk/python/kfp/compiler/pipeline_spec_builder.py index 3f1575005da..6433a9e4a30 100644 --- a/sdk/python/kfp/compiler/pipeline_spec_builder.py +++ b/sdk/python/kfp/compiler/pipeline_spec_builder.py @@ -2071,11 +2071,11 @@ def write_pipeline_spec_to_file( def _merge_pipeline_config(pipelineConfig: pipeline_config.PipelineConfig, platformSpec: pipeline_spec_pb2.PlatformSpec): - # TODO: add pipeline config options (ttl, semaphore, etc.) to the dict - # json_format.ParseDict( - # {'pipelineConfig': { - # '': pipelineConfig., - # }}, platformSpec.platforms['kubernetes']) + json_format.ParseDict( + {'pipelineConfig': { + 'semaphoreName': pipelineConfig.semaphore_name, + 'mutexName': pipelineConfig.mutex_name, + }}, platformSpec.platforms['kubernetes']) return platformSpec diff --git a/sdk/python/kfp/dsl/pipeline_config.py b/sdk/python/kfp/dsl/pipeline_config.py index a4e90c28a01..1872afda525 100644 --- a/sdk/python/kfp/dsl/pipeline_config.py +++ b/sdk/python/kfp/dsl/pipeline_config.py @@ -15,9 +15,26 @@ class PipelineConfig: - """PipelineConfig contains pipeline-level config options.""" + """ + PipelineConfig contains pipeline-level config options. + """ def __init__(self): - pass + self.semaphore_name = None + self.mutex_name = None - # TODO add pipeline level configs + def set_semaphore_name(self, semaphore_name: str): + """Set the name of the semaphore to control pipeline concurrency. + + Args: + semaphore_name (str): Name of the semaphore. + """ + self.semaphore_name = semaphore_name.strip() + + def set_mutex_name(self, mutex_name: str): + """Set the name of the mutex to ensure mutual exclusion. + + Args: + mutex_name (str): Name of the mutex. + """ + self.mutex_name = mutex_name.strip()