Delete job via api client

delete_job_snip.go

	for _, job := range jobs {
		// get uid and created jobs
		uid := job.GetObjectMeta().GetUID()

		// Delete job first. See https://github.com/kubernetes/kubernetes/issues/43168
		err := clientset.BatchV1().Jobs(job.GetNamespace()).Delete(job.GetName(), &metav1.DeleteOptions{})

		if err != nil {
			return i, fmt.Errorf("failed to delete job %s/%s: %s", job.GetNamespace(), job.GetName(), err)
		} else {
			i++
			log.Infof("successfully deleted job %s/%s", job.GetNamespace(), job.GetName())
		}
    
    // Delete associated pods
		childPods, err := GetPodsWithUidLabel(clientset, uid, job.GetNamespace())

		log.Infof("Deleting %d associated pods for job %s/%s", len(childPods.Items), job.GetNamespace(), job.GetName())

		if err != nil {
			return i, fmt.Errorf("failed to get child pods: %s", err)
		}

		for _, pod := range childPods.Items {
			err := clientset.CoreV1().Pods(job.GetNamespace()).Delete(pod.GetName(), nil)
			if err != nil {
				return i, fmt.Errorf("failed to delete associated pod %s: %s", pod.GetName(), err)
			}

			log.Infof("Deleted associated pod %s", pod.GetName())
		}
}