generate new manifest

kubeflow · Aug 12, 2024 · 366c1c2 · 366c1c2
1 parent 4f5c8e6
commit 366c1c2
Show file tree

Hide file tree

Showing 25 changed files with 90 additions and 1 deletion.
diff --git a/docs/api/kubeflow.org_v1_generated.asciidoc b/docs/api/kubeflow.org_v1_generated.asciidoc
@@ -677,6 +677,20 @@ Suspending a Job will reset the StartTime field of the Job.
 
 
 Defaults to false.
+| *`managedBy`* __string__ | ManagedBy is used to indicate the controller or entity that manages a job.
+The value must be either an empty, 'kubeflow.org/training-operator' or
+'kueue.x-k8s.io/multikueue'.
+The built-in job controller reconciles a job which don't have this
+field at all or the field value is the reserved string
+'kubeflow.org/training-operator', but delegates reconciling the job
+with a 'kueue.x-k8s.io/multikueue' to the Kueue.
+
+
+The value must be a valid domain-prefixed path (e.g. acme.io/foo) -
+all characters before the first "/" must be a valid subdomain as defined
+by RFC 1123. All characters trailing the first "/" must be valid HTTP Path
+characters as defined by RFC 3986. The value cannot exceed 63 characters.
+The field is immutable.
 |===
 
 

diff --git a/hack/python-sdk/swagger.json b/hack/python-sdk/swagger.json
@@ -575,6 +575,10 @@
           "description": "CleanPodPolicy defines the policy to kill pods after the job completes. Default to None.",
           "type": "string"
         },
+        "managedBy": {
+          "description": "ManagedBy is used to indicate the controller or entity that manages a job. The value must be either an empty, 'kubeflow.org/training-operator' or 'kueue.x-k8s.io/multikueue'. The built-in job controller reconciles a job which don't have this field at all or the field value is the reserved string 'kubeflow.org/training-operator', but delegates reconciling the job with a 'kueue.x-k8s.io/multikueue' to the Kueue.\n\nThe value must be a valid domain-prefixed path (e.g. acme.io/foo) - all characters before the first \"/\" must be a valid subdomain as defined by RFC 1123. All characters trailing the first \"/\" must be valid HTTP Path characters as defined by RFC 3986. The value cannot exceed 63 characters. The field is immutable.",
+          "type": "string"
+        },
         "schedulingPolicy": {
           "description": "SchedulingPolicy defines the policy related to scheduling, e.g. gang-scheduling",
           "$ref": "#/definitions/kubeflow.org.v1.SchedulingPolicy"

diff --git a/pkg/apis/kubeflow.org/v1/openapi_generated.go b/pkg/apis/kubeflow.org/v1/openapi_generated.go
diff --git a/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go b/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go
diff --git a/sdk/python/docs/KubeflowOrgV1RunPolicy.md b/sdk/python/docs/KubeflowOrgV1RunPolicy.md
@@ -7,6 +7,7 @@ Name | Type | Description | Notes
 **active_deadline_seconds** | **int** | Specifies the duration in seconds relative to the startTime that the job may be active before the system tries to terminate it; value must be positive integer. | [optional] 
 **backoff_limit** | **int** | Optional number of retries before marking this job failed. | [optional] 
 **clean_pod_policy** | **str** | CleanPodPolicy defines the policy to kill pods after the job completes. Default to None. | [optional] 
+**managed_by** | **str** | ManagedBy is used to indicate the controller or entity that manages a job. The value must be either an empty, &#39;kubeflow.org/training-operator&#39; or &#39;kueue.x-k8s.io/multikueue&#39;. The built-in job controller reconciles a job which don&#39;t have this field at all or the field value is the reserved string &#39;kubeflow.org/training-operator&#39;, but delegates reconciling the job with a &#39;kueue.x-k8s.io/multikueue&#39; to the Kueue.  The value must be a valid domain-prefixed path (e.g. acme.io/foo) - all characters before the first \&quot;/\&quot; must be a valid subdomain as defined by RFC 1123. All characters trailing the first \&quot;/\&quot; must be valid HTTP Path characters as defined by RFC 3986. The value cannot exceed 63 characters. The field is immutable. | [optional] 
 **scheduling_policy** | [**KubeflowOrgV1SchedulingPolicy**](KubeflowOrgV1SchedulingPolicy.md) |  | [optional] 
 **suspend** | **bool** | suspend specifies whether the Job controller should create Pods or not. If a Job is created with suspend set to true, no Pods are created by the Job controller. If a Job is suspended after creation (i.e. the flag goes from false to true), the Job controller will delete all active Pods and PodGroups associated with this Job. Users must design their workload to gracefully handle this. Suspending a Job will reset the StartTime field of the Job.  Defaults to false. | [optional] 
 **ttl_seconds_after_finished** | **int** | TTLSecondsAfterFinished is the TTL to clean up jobs. It may take extra ReconcilePeriod seconds for the cleanup, since reconcile gets called periodically. Default to infinite. | [optional] 

diff --git a/sdk/python/kubeflow/training/models/kubeflow_org_v1_run_policy.py b/sdk/python/kubeflow/training/models/kubeflow_org_v1_run_policy.py
@@ -36,6 +36,7 @@ class KubeflowOrgV1RunPolicy(object):
         'active_deadline_seconds': 'int',
         'backoff_limit': 'int',
         'clean_pod_policy': 'str',
+        'managed_by': 'str',
         'scheduling_policy': 'KubeflowOrgV1SchedulingPolicy',
         'suspend': 'bool',
         'ttl_seconds_after_finished': 'int'
@@ -45,12 +46,13 @@ class KubeflowOrgV1RunPolicy(object):
         'active_deadline_seconds': 'activeDeadlineSeconds',
         'backoff_limit': 'backoffLimit',
         'clean_pod_policy': 'cleanPodPolicy',
+        'managed_by': 'managedBy',
         'scheduling_policy': 'schedulingPolicy',
         'suspend': 'suspend',
         'ttl_seconds_after_finished': 'ttlSecondsAfterFinished'
     }
 
-    def __init__(self, active_deadline_seconds=None, backoff_limit=None, clean_pod_policy=None, scheduling_policy=None, suspend=None, ttl_seconds_after_finished=None, local_vars_configuration=None):  # noqa: E501
+    def __init__(self, active_deadline_seconds=None, backoff_limit=None, clean_pod_policy=None, managed_by=None, scheduling_policy=None, suspend=None, ttl_seconds_after_finished=None, local_vars_configuration=None):  # noqa: E501
         """KubeflowOrgV1RunPolicy - a model defined in OpenAPI"""  # noqa: E501
         if local_vars_configuration is None:
             local_vars_configuration = Configuration()
@@ -59,6 +61,7 @@ def __init__(self, active_deadline_seconds=None, backoff_limit=None, clean_pod_p
         self._active_deadline_seconds = None
         self._backoff_limit = None
         self._clean_pod_policy = None
+        self._managed_by = None
         self._scheduling_policy = None
         self._suspend = None
         self._ttl_seconds_after_finished = None
@@ -70,6 +73,8 @@ def __init__(self, active_deadline_seconds=None, backoff_limit=None, clean_pod_p
             self.backoff_limit = backoff_limit
         if clean_pod_policy is not None:
             self.clean_pod_policy = clean_pod_policy
+        if managed_by is not None:
+            self.managed_by = managed_by
         if scheduling_policy is not None:
             self.scheduling_policy = scheduling_policy
         if suspend is not None:
@@ -146,6 +151,29 @@ def clean_pod_policy(self, clean_pod_policy):
 
         self._clean_pod_policy = clean_pod_policy
 
+    @property
+    def managed_by(self):
+        """Gets the managed_by of this KubeflowOrgV1RunPolicy.  # noqa: E501
+
+        ManagedBy is used to indicate the controller or entity that manages a job. The value must be either an empty, 'kubeflow.org/training-operator' or 'kueue.x-k8s.io/multikueue'. The built-in job controller reconciles a job which don't have this field at all or the field value is the reserved string 'kubeflow.org/training-operator', but delegates reconciling the job with a 'kueue.x-k8s.io/multikueue' to the Kueue.  The value must be a valid domain-prefixed path (e.g. acme.io/foo) - all characters before the first \"/\" must be a valid subdomain as defined by RFC 1123. All characters trailing the first \"/\" must be valid HTTP Path characters as defined by RFC 3986. The value cannot exceed 63 characters. The field is immutable.  # noqa: E501
+
+        :return: The managed_by of this KubeflowOrgV1RunPolicy.  # noqa: E501
+        :rtype: str
+        """
+        return self._managed_by
+
+    @managed_by.setter
+    def managed_by(self, managed_by):
+        """Sets the managed_by of this KubeflowOrgV1RunPolicy.
+
+        ManagedBy is used to indicate the controller or entity that manages a job. The value must be either an empty, 'kubeflow.org/training-operator' or 'kueue.x-k8s.io/multikueue'. The built-in job controller reconciles a job which don't have this field at all or the field value is the reserved string 'kubeflow.org/training-operator', but delegates reconciling the job with a 'kueue.x-k8s.io/multikueue' to the Kueue.  The value must be a valid domain-prefixed path (e.g. acme.io/foo) - all characters before the first \"/\" must be a valid subdomain as defined by RFC 1123. All characters trailing the first \"/\" must be valid HTTP Path characters as defined by RFC 3986. The value cannot exceed 63 characters. The field is immutable.  # noqa: E501
+
+        :param managed_by: The managed_by of this KubeflowOrgV1RunPolicy.  # noqa: E501
+        :type: str
+        """
+
+        self._managed_by = managed_by
+
     @property
     def scheduling_policy(self):
         """Gets the scheduling_policy of this KubeflowOrgV1RunPolicy.  # noqa: E501

diff --git a/sdk/python/test/test_kubeflow_org_v1_jax_job.py b/sdk/python/test/test_kubeflow_org_v1_jax_job.py
@@ -50,6 +50,7 @@ def make_instance(self, include_optional):
                         active_deadline_seconds = 56, 
                         backoff_limit = 56, 
                         clean_pod_policy = '0', 
+                        managed_by = '0', 
                         scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                             min_available = 56, 
                             min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_jax_job_list.py b/sdk/python/test/test_kubeflow_org_v1_jax_job_list.py
@@ -53,6 +53,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {
@@ -106,6 +107,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_jax_job_spec.py b/sdk/python/test/test_kubeflow_org_v1_jax_job_spec.py
@@ -46,6 +46,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {
@@ -69,6 +70,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_mpi_job.py b/sdk/python/test/test_kubeflow_org_v1_mpi_job.py
@@ -52,6 +52,7 @@ def make_instance(self, include_optional):
                         active_deadline_seconds = 56, 
                         backoff_limit = 56, 
                         clean_pod_policy = '0', 
+                        managed_by = '0', 
                         scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                             min_available = 56, 
                             min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_mpi_job_list.py b/sdk/python/test/test_kubeflow_org_v1_mpi_job_list.py
@@ -55,6 +55,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {
@@ -111,6 +112,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_mpi_job_spec.py b/sdk/python/test/test_kubeflow_org_v1_mpi_job_spec.py
@@ -48,6 +48,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_paddle_job.py b/sdk/python/test/test_kubeflow_org_v1_paddle_job.py
@@ -57,6 +57,7 @@ def make_instance(self, include_optional):
                         active_deadline_seconds = 56, 
                         backoff_limit = 56, 
                         clean_pod_policy = '0', 
+                        managed_by = '0', 
                         scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                             min_available = 56, 
                             min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_paddle_job_list.py b/sdk/python/test/test_kubeflow_org_v1_paddle_job_list.py
@@ -60,6 +60,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {
@@ -120,6 +121,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_paddle_job_spec.py b/sdk/python/test/test_kubeflow_org_v1_paddle_job_spec.py
@@ -53,6 +53,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {
@@ -76,6 +77,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_py_torch_job.py b/sdk/python/test/test_kubeflow_org_v1_py_torch_job.py
@@ -69,6 +69,7 @@ def make_instance(self, include_optional):
                         active_deadline_seconds = 56, 
                         backoff_limit = 56, 
                         clean_pod_policy = '0', 
+                        managed_by = '0', 
                         scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                             min_available = 56, 
                             min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_py_torch_job_list.py b/sdk/python/test/test_kubeflow_org_v1_py_torch_job_list.py
@@ -72,6 +72,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {
@@ -144,6 +145,7 @@ def make_instance(self, include_optional):
                                 active_deadline_seconds = 56, 
                                 backoff_limit = 56, 
                                 clean_pod_policy = '0', 
+                                managed_by = '0', 
                                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                                     min_available = 56, 
                                     min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_py_torch_job_spec.py b/sdk/python/test/test_kubeflow_org_v1_py_torch_job_spec.py
@@ -65,6 +65,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {
@@ -88,6 +89,7 @@ def make_instance(self, include_optional):
                     active_deadline_seconds = 56, 
                     backoff_limit = 56, 
                     clean_pod_policy = '0', 
+                    managed_by = '0', 
                     scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                         min_available = 56, 
                         min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_run_policy.py b/sdk/python/test/test_kubeflow_org_v1_run_policy.py
@@ -39,6 +39,7 @@ def make_instance(self, include_optional):
                 active_deadline_seconds = 56, 
                 backoff_limit = 56, 
                 clean_pod_policy = '0', 
+                managed_by = '0', 
                 scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                     min_available = 56, 
                     min_resources = {

diff --git a/sdk/python/test/test_kubeflow_org_v1_tf_job.py b/sdk/python/test/test_kubeflow_org_v1_tf_job.py
@@ -45,6 +45,7 @@ def make_instance(self, include_optional):
                         active_deadline_seconds = 56, 
                         backoff_limit = 56, 
                         clean_pod_policy = '0', 
+                        managed_by = '0', 
                         scheduling_policy = kubeflow_org_v1_scheduling_policy.KubeflowOrgV1SchedulingPolicy(
                             min_available = 56, 
                             min_resources = {