From 366c1c23239d83dd8da4019093ff8f94fe2803dd Mon Sep 17 00:00:00 2001 From: Michal Szadkowski Date: Fri, 9 Aug 2024 11:58:22 +0200 Subject: [PATCH] generate new manifest --- docs/api/kubeflow.org_v1_generated.asciidoc | 14 +++++++++ hack/python-sdk/swagger.json | 4 +++ pkg/apis/kubeflow.org/v1/openapi_generated.go | 7 +++++ .../kubeflow.org/v1/zz_generated.deepcopy.go | 5 ++++ sdk/python/docs/KubeflowOrgV1RunPolicy.md | 1 + .../models/kubeflow_org_v1_run_policy.py | 30 ++++++++++++++++++- .../test/test_kubeflow_org_v1_jax_job.py | 1 + .../test/test_kubeflow_org_v1_jax_job_list.py | 2 ++ .../test/test_kubeflow_org_v1_jax_job_spec.py | 2 ++ .../test/test_kubeflow_org_v1_mpi_job.py | 1 + .../test/test_kubeflow_org_v1_mpi_job_list.py | 2 ++ .../test/test_kubeflow_org_v1_mpi_job_spec.py | 1 + .../test/test_kubeflow_org_v1_paddle_job.py | 1 + .../test_kubeflow_org_v1_paddle_job_list.py | 2 ++ .../test_kubeflow_org_v1_paddle_job_spec.py | 2 ++ .../test/test_kubeflow_org_v1_py_torch_job.py | 1 + .../test_kubeflow_org_v1_py_torch_job_list.py | 2 ++ .../test_kubeflow_org_v1_py_torch_job_spec.py | 2 ++ .../test/test_kubeflow_org_v1_run_policy.py | 1 + .../test/test_kubeflow_org_v1_tf_job.py | 1 + .../test/test_kubeflow_org_v1_tf_job_list.py | 2 ++ .../test/test_kubeflow_org_v1_tf_job_spec.py | 2 ++ .../test/test_kubeflow_org_v1_xg_boost_job.py | 1 + .../test_kubeflow_org_v1_xg_boost_job_list.py | 2 ++ .../test_kubeflow_org_v1_xg_boost_job_spec.py | 2 ++ 25 files changed, 90 insertions(+), 1 deletion(-) diff --git a/docs/api/kubeflow.org_v1_generated.asciidoc b/docs/api/kubeflow.org_v1_generated.asciidoc index 3648d52e4d..6b3599a4f2 100644 --- 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 index a158dd8748..0f9f92856a 100644 --- 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 index d6f32b1142..8fe8710b20 100644 --- a/pkg/apis/kubeflow.org/v1/openapi_generated.go +++ b/pkg/apis/kubeflow.org/v1/openapi_generated.go @@ -1063,6 +1063,13 @@ func schema_pkg_apis_kubefloworg_v1_RunPolicy(ref common.ReferenceCallback) comm Format: "", }, }, + "managedBy": { + SchemaProps: spec.SchemaProps{ + 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{"string"}, + Format: "", + }, + }, }, }, }, diff --git a/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go b/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go index 79ca131cd5..52ce7b75e6 100644 --- a/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go +++ b/pkg/apis/kubeflow.org/v1/zz_generated.deepcopy.go @@ -680,6 +680,11 @@ func (in *RunPolicy) DeepCopyInto(out *RunPolicy) { *out = new(bool) **out = **in } + if in.ManagedBy != nil { + in, out := &in.ManagedBy, &out.ManagedBy + *out = new(string) + **out = **in + } } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunPolicy. diff --git a/sdk/python/docs/KubeflowOrgV1RunPolicy.md b/sdk/python/docs/KubeflowOrgV1RunPolicy.md index ce41fa09f6..bcbadfaa10 100644 --- 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, '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. | [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 index c5fd48bc9a..7d30f3e41c 100644 --- 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 index 05c9e07d4c..f252ecd54d 100644 --- 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 index 4f92324581..cfdf269e43 100644 --- 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 index 7e023b261b..02da4bb580 100644 --- 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 index 1f8f164cf9..2f2eccdf8e 100644 --- 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 index 4406dc67e1..ee3248e160 100644 --- 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 index c042104169..4142c43a0c 100644 --- 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 index 17759aa30a..e0e213f6cb 100644 --- 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 index e82d533a1f..d11b9484fa 100644 --- 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 index 71029311b3..4b7e759a42 100644 --- 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 index 4a85f5ed46..716555cf75 100644 --- 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 index 2cbafc65de..be2e21f2c4 100644 --- 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 index f19f3f2fd1..eb73d0c63c 100644 --- 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 index 525be1d785..a279e0c722 100644 --- 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 index fa1cf4a6bc..8d8e89c94d 100644 --- 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 = { diff --git a/sdk/python/test/test_kubeflow_org_v1_tf_job_list.py b/sdk/python/test/test_kubeflow_org_v1_tf_job_list.py index 6f7c46d212..5dbb8fd138 100644 --- a/sdk/python/test/test_kubeflow_org_v1_tf_job_list.py +++ b/sdk/python/test/test_kubeflow_org_v1_tf_job_list.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 = { @@ -103,6 +104,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_spec.py b/sdk/python/test/test_kubeflow_org_v1_tf_job_spec.py index 892fb43578..9448020c3e 100644 --- a/sdk/python/test/test_kubeflow_org_v1_tf_job_spec.py +++ b/sdk/python/test/test_kubeflow_org_v1_tf_job_spec.py @@ -41,6 +41,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 = { @@ -65,6 +66,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_xg_boost_job.py b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job.py index 88e6de1793..324bad50d7 100644 --- a/sdk/python/test/test_kubeflow_org_v1_xg_boost_job.py +++ b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job.py @@ -44,6 +44,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_xg_boost_job_list.py b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_list.py index 5cdfdd931d..de4dd000f2 100644 --- a/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_list.py +++ b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_list.py @@ -47,6 +47,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 = { @@ -100,6 +101,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_xg_boost_job_spec.py b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_spec.py index 222f29f84a..c7206b01f1 100644 --- a/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_spec.py +++ b/sdk/python/test/test_kubeflow_org_v1_xg_boost_job_spec.py @@ -40,6 +40,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 = { @@ -63,6 +64,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 = {