Skip to content

Commit 4cf8c95

Browse files
authored
Merge pull request #49 from doyoubi/fix/DeleteNode
Flush cache before deleting nodes
2 parents d820d6f + 0e51a1d commit 4cf8c95

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

ruskit/cluster.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -370,6 +370,9 @@ def reshard(self):
370370
self.migrate(src, n["node"], count)
371371

372372
def delete_node(self, node):
373+
node.flush_cache()
374+
self.flush_all_cache()
375+
373376
if node.is_master():
374377
self.migrate_node(node)
375378

0 commit comments

Comments
 (0)