diff --git a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go index d809e54f8fe..c81f0d64c21 100644 --- a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go +++ b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go @@ -2746,16 +2746,12 @@ func (x *KubernetesWorkspaceConfig) GetPvcSpecPatch() *structpb.Struct { // Spec for pipeline-level config options. See PipelineConfig DSL class. type PipelineConfig struct { state protoimpl.MessageState `protogen:"open.v1"` - // Name of the semaphore key to control pipeline concurrency - SemaphoreKey string `protobuf:"bytes,1,opt,name=semaphore_key,json=semaphoreKey,proto3" json:"semaphore_key,omitempty"` - // Name of the mutex to ensure mutual exclusion - MutexName string `protobuf:"bytes,2,opt,name=mutex_name,json=mutexName,proto3" json:"mutex_name,omitempty"` // Time to live configuration after the pipeline run is completed for // ephemeral resources created by the pipeline run. - ResourceTtl int32 `protobuf:"varint,3,opt,name=resource_ttl,json=resourceTtl,proto3" json:"resource_ttl,omitempty"` + ResourceTtl int32 `protobuf:"varint,1,opt,name=resource_ttl,json=resourceTtl,proto3" json:"resource_ttl,omitempty"` // Configuration for a shared storage workspace that persists for the duration of the pipeline run. // The workspace can be configured with size and Kubernetes-specific settings to override default PVC configurations. - Workspace *WorkspaceConfig `protobuf:"bytes,4,opt,name=workspace,proto3,oneof" json:"workspace,omitempty"` + Workspace *WorkspaceConfig `protobuf:"bytes,2,opt,name=workspace,proto3,oneof" json:"workspace,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -2790,20 +2786,6 @@ func (*PipelineConfig) Descriptor() ([]byte, []int) { return file_pipeline_spec_proto_rawDescGZIP(), []int{34} } -func (x *PipelineConfig) GetSemaphoreKey() string { - if x != nil { - return x.SemaphoreKey - } - return "" -} - -func (x *PipelineConfig) GetMutexName() string { - if x != nil { - return x.MutexName - } - return "" -} - func (x *PipelineConfig) GetResourceTtl() int32 { if x != nil { return x.ResourceTtl @@ -6105,13 +6087,10 @@ const file_pipeline_spec_proto_rawDesc = "" + "\v_kubernetes\"r\n" + "\x19KubernetesWorkspaceConfig\x12B\n" + "\x0epvc_spec_patch\x18\x01 \x01(\v2\x17.google.protobuf.StructH\x00R\fpvcSpecPatch\x88\x01\x01B\x11\n" + - "\x0f_pvc_spec_patch\"\xc7\x01\n" + - "\x0ePipelineConfig\x12#\n" + - "\rsemaphore_key\x18\x01 \x01(\tR\fsemaphoreKey\x12\x1d\n" + - "\n" + - "mutex_name\x18\x02 \x01(\tR\tmutexName\x12!\n" + - "\fresource_ttl\x18\x03 \x01(\x05R\vresourceTtl\x12@\n" + - "\tworkspace\x18\x04 \x01(\v2\x1d.ml_pipelines.WorkspaceConfigH\x00R\tworkspace\x88\x01\x01B\f\n" + + "\x0f_pvc_spec_patch\"\x83\x01\n" + + "\x0ePipelineConfig\x12!\n" + + "\fresource_ttl\x18\x01 \x01(\x05R\vresourceTtl\x12@\n" + + "\tworkspace\x18\x02 \x01(\v2\x1d.ml_pipelines.WorkspaceConfigH\x00R\tworkspace\x88\x01\x01B\f\n" + "\n" + "_workspaceB Optional[str]: - """Get the semaphore key for controlling pipeline concurrency. - - Returns: - Optional[str]: The semaphore key, or None if not set. - """ - return self._semaphore_key - - @semaphore_key.setter - def semaphore_key(self, value: str): - """Set the semaphore key to control pipeline concurrency. - - Pipelines with the same semaphore key will be limited to a configured maximum - number of concurrent executions. This allows you to control resource usage by - ensuring that only a specific number of pipelines can run simultaneously. - - Note: A pipeline can use both semaphores and mutexes together. The pipeline - will wait until all required locks are available before starting. - - Args: - value (str): The semaphore key name for controlling concurrent executions. - """ - self._semaphore_key = (value and value.strip()) or None - - @property - def mutex_name(self) -> Optional[str]: - """Get the mutex name for exclusive pipeline execution. - - Returns: - Optional[str]: The mutex name, or None if not set. - """ - return self._mutex_name - - @mutex_name.setter - def mutex_name(self, value: str): - """Set the name of the mutex to ensure mutual exclusion. - - Pipelines with the same mutex name will only run one at a time. This ensures - exclusive access to shared resources and prevents conflicts when multiple - pipelines would otherwise compete for the same resources. - - Args: - value (str): Name of the mutex for exclusive pipeline execution. - """ - self._mutex_name = (value and value.strip()) or None