diff --git a/app/horus/core/horuser/node_drain.go b/app/horus/core/horuser/node_drain.go
index b60d07e4..ff098b8f 100644
--- a/app/horus/core/horuser/node_drain.go
+++ b/app/horus/core/horuser/node_drain.go
@@ -33,7 +33,7 @@ func (h *Horuser) Drain(nodeName, clusterName string) (err error) {
 
 	ctxFirst, cancelFirst := h.GetK8sContext()
 	defer cancelFirst()
-	listOpts := v1.ListOptions{FieldSelector: fmt.Sprintf("nodeName=%s", nodeName)}
+	listOpts := v1.ListOptions{FieldSelector: fmt.Sprintf("spec.nodeName=%s", nodeName)}
 	var podNamespace string
 	pod, err := kubeClient.CoreV1().Pods(podNamespace).List(ctxFirst, listOpts)
 	if err != nil {