diff --git a/node-daemon/pvcd/NodeInstance.py b/node-daemon/pvcd/NodeInstance.py index 0281ee8d..363a37b1 100644 --- a/node-daemon/pvcd/NodeInstance.py +++ b/node-daemon/pvcd/NodeInstance.py @@ -362,8 +362,8 @@ class NodeInstance(object): target_node = findTargetHypervisor(self.zk_conn, 'mem', dom_uuid) # Don't replace the previous node if the VM is already migrated - if zkhandler.readdata(self.zk_conn, '/domains/{}/migrated') is 'yes': - current_node = zkhandler.readdata(self.zk_conn, '/domains/{}/lastnode') + if zkhandler.readdata(self.zk_conn, '/domains/{}/migrated'.format(dom_uuid)) == 'yes': + current_node = zkhandler.readdata(self.zk_conn, '/domains/{}/lastnode'.format(dom_uuid)) else: current_node = zkhandler.readdata(self.zk_conn, '/domains/{}/node'.format(dom_uuid))