Merge pull request openstack-k8s-operators#1154 from rabi/job_nodesel…

…ector Add nodeselector for ansible jobs
bshephar · Oct 26, 2024 · c2f6677 · c2f6677
2 parents 0b1d305 + 02f47e5
commit c2f6677
Show file tree

Hide file tree

Showing 6 changed files with 26 additions and 0 deletions.
diff --git a/apis/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml b/apis/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml
@@ -46,6 +46,10 @@ spec:
             properties:
               ansibleExtraVars:
                 x-kubernetes-preserve-unknown-fields: true
+              ansibleJobNodeSelector:
+                additionalProperties:
+                  type: string
+                type: object
               ansibleLimit:
                 type: string
               ansibleSkipTags:

diff --git a/apis/dataplane/v1beta1/openstackdataplanedeployment_types.go b/apis/dataplane/v1beta1/openstackdataplanedeployment_types.go
@@ -67,6 +67,10 @@ type OpenStackDataPlaneDeploymentSpec struct {
 	// +kubebuilder:validation:Minimum:=1
 	// +kubebuilder:default:=15
 	DeploymentRequeueTime int `json:"deploymentRequeueTime"`
+
+	// +kubebuilder:validation:Optional
+	// AnsibleJobNodeSelector to target subset of worker nodes running the ansible jobs
+	AnsibleJobNodeSelector map[string]string `json:"ansibleJobNodeSelector,omitempty"`
 }
 
 // OpenStackDataPlaneDeploymentStatus defines the observed state of OpenStackDataPlaneDeployment

diff --git a/apis/dataplane/v1beta1/zz_generated.deepcopy.go b/apis/dataplane/v1beta1/zz_generated.deepcopy.go
diff --git a/config/crd/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml b/config/crd/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml
@@ -46,6 +46,10 @@ spec:
             properties:
               ansibleExtraVars:
                 x-kubernetes-preserve-unknown-fields: true
+              ansibleJobNodeSelector:
+                additionalProperties:
+                  type: string
+                type: object
               ansibleLimit:
                 type: string
               ansibleSkipTags:

diff --git a/pkg/dataplane/util/ansible_execution.go b/pkg/dataplane/util/ansible_execution.go
@@ -84,6 +84,7 @@ func AnsibleExecution(
 
 	ansibleEE.ExtraMounts = append(aeeSpec.ExtraMounts, []storage.VolMounts{ansibleEEMounts}...)
 	ansibleEE.Env = aeeSpec.Env
+	ansibleEE.NodeSelector = deployment.Spec.AnsibleJobNodeSelector
 
 	currentJobHash := deployment.Status.AnsibleEEHashes[ansibleEE.Name]
 	jobDef, err := ansibleEE.JobForOpenStackAnsibleEE(helper)

diff --git a/pkg/dataplane/util/ansibleee.go b/pkg/dataplane/util/ansibleee.go
@@ -63,6 +63,8 @@ type EEJob struct {
 	Annotations map[string]string `json:"annotations,omitempty"`
 	// Env is a list containing the environment variables to pass to the pod
 	Env []corev1.EnvVar `json:"env,omitempty"`
+	// NodeSelector to target subset of worker nodes running the ansible jobs
+	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
 }
 
 // JobForOpenStackAnsibleEE returns a openstackansibleee Job object
@@ -103,6 +105,10 @@ func (a *EEJob) JobForOpenStackAnsibleEE(h *helper.Helper) (*batchv1.Job, error)
 		}},
 	}
 
+	if a.NodeSelector != nil && len(a.NodeSelector) > 0 {
+		podSpec.NodeSelector = a.NodeSelector
+	}
+
 	if a.DNSConfig != nil {
 		podSpec.DNSConfig = a.DNSConfig
 		podSpec.DNSPolicy = "None"