We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b4d18d3 commit ca452a4Copy full SHA for ca452a4
internal/controller/scripts/pre_stop.sh
@@ -29,4 +29,18 @@ echo "Pause writes"
29
valkey-cli -c CLIENT PAUSE "5000" WRITE
30
31
valkey-cli -h "${SLAVE_IP}" -p "${SLAVE_PORT}" -c cluster failover
32
-sleep 3s
+
33
+check_failover_complete() {
34
+ ROLE=$(valkey-cli -h "${SLAVE_IP}" -p "${SLAVE_PORT}" INFO REPLICATION | grep role | cut -d':' -f2 | tr -d '\r')
35
+ if [ "${ROLE}" = "master" ]; then
36
+ return 0
37
+ else
38
+ return 1
39
+ fi
40
+}
41
42
+echo "Waiting for failover to complete..."
43
+while ! check_failover_complete; do
44
+ echo "Failover in progress, waiting..."
45
+ sleep 1
46
+done
0 commit comments