func()

in pkg/azure/workqueue.go [81:101]

• 21 lines of code
• 5 McCabe index (conditional complexity)

func (w *Worker) drainChan(defaultEvent Job) []*corev1.Node {
	var nodesWithFwTaint []*corev1.Node
	c := 0
	for {
		select {
		case event := <-w.Queue.jobs:
			resourceName := event.Request.NamespacedName.Name
			jobsInQueue.Set(resourceName, false)
			c = c + 1
			node := &corev1.Node{}
			if err := w.client.Get(event.ctx, event.Request.NamespacedName, node); err == nil {
				if CheckIfTaintExists(node) {
					nodesWithFwTaint = append(nodesWithFwTaint, node)
				}
			}
		default:
			klog.Infof("Draining %d events from work channel", c)
			return nodesWithFwTaint
		}
	}
}