diff --git a/pvc.py b/pvc.py
index 6521b49a..17152944 100755
--- a/pvc.py
+++ b/pvc.py
@@ -411,7 +411,7 @@ def flush_host(node, wait):
     if wait == True:
         while True:
             time.sleep(1)
-            node_state = zk_conn.get('/nodes/{}/state'.format(node))[0].decode('ascii')
+            node_state = zk_conn.get('/nodes/{}/domainstate'.format(node))[0].decode('ascii')
             if node_state == "flushed":
                 break