Merge pull request #13695 from rabbitmq/mergify/bp/v4.0.x/pr-13694

Update khepri_mnesia_migration from 0.7.1 to 0.7.2 (backport #13686) (backport #13694)

Author: dumbbell

deps/rabbit/test/quorum_queue_SUITE.erl

@@ -2423,11 +2423,21 @@ confirm_availability_on_leader_change(Config) ->
     ok.
 
 wait_for_new_messages(Config, Node, Name, Increase) ->
+    wait_for_new_messages(Config, Node, Name, Increase, 60000).
+
+wait_for_new_messages(Config, Node, Name, Increase, Timeout) ->
     Infos = rabbit_ct_broker_helpers:rabbitmqctl_list(
               Config, Node, ["list_queues", "name", "messages"]),
-    [[Name, Msgs0]] = [Props || Props <- Infos, hd(Props) == Name],
-    Msgs = binary_to_integer(Msgs0),
-    queue_utils:wait_for_min_messages(Config, Name, Msgs + Increase).
+    case [Props || Props <- Infos, hd(Props) == Name] of
+        [[Name, Msgs0]] ->
+            Msgs = binary_to_integer(Msgs0),
+            queue_utils:wait_for_min_messages(Config, Name, Msgs + Increase);
+        _ when Timeout >= 0 ->
+            Sleep = 200,
+            timer:sleep(Sleep),
+            wait_for_new_messages(
+              Config, Node, Name, Increase, Timeout - Sleep)
+    end.
 
 flush(T) ->
     receive X ->

rabbitmq-components.mk

@@ -47,7 +47,7 @@ dep_cuttlefish = hex 3.4.0
 dep_gen_batch_server = hex 0.8.8
 dep_jose = hex 1.11.10
 dep_khepri = hex 0.16.0
-dep_khepri_mnesia_migration = hex 0.7.1
+dep_khepri_mnesia_migration = hex 0.7.2
 dep_meck = hex 1.0.0
 dep_osiris = git https://github.com/rabbitmq/osiris v1.8.6
 dep_prometheus = hex 4.11.0