Update Khepri + Dialyzer fix

Author: dumbbell

MODULE.bazel

@@ -287,7 +287,7 @@ erlang_package.hex_package(
 erlang_package.git_package(
     name = "khepri",
     build_file = "@rabbitmq-server//bazel:BUILD.khepri",
-    commit = "24e33d5c2656b0f05404e97c2b7d763d1a799650",
+    commit = "cb52d575903ddb0e0f13d2ac9ee819b046f9d598",
     repository = "rabbitmq/khepri",
 )
 

deps/rabbit/Makefile

@@ -151,7 +151,7 @@ dep_syslog = git https://github.com/schlagert/syslog 4.0.0
 dep_osiris = git https://github.com/rabbitmq/osiris v1.6.7
 dep_systemd = hex 0.6.1
 dep_seshat = git https://github.com/rabbitmq/seshat v0.6.1
-dep_khepri = git https://github.com/rabbitmq/khepri 24e33d5c2656b0f05404e97c2b7d763d1a799650
+dep_khepri = git https://github.com/rabbitmq/khepri cb52d575903ddb0e0f13d2ac9ee819b046f9d598
 dep_khepri_mnesia_migration = hex 0.1.1
 
 define usage_xml_to_erl

deps/rabbit/src/rabbit_db_queue.erl

@@ -78,6 +78,9 @@
          khepri_queues_path/0
         ]).
 
+-dialyzer({nowarn_function, [foreach_transient/1,
+                             foreach_transient_in_khepri/1]}).
+
 -define(MNESIA_TABLE, rabbit_queue).
 -define(MNESIA_DURABLE_TABLE, rabbit_durable_queue).
 
@@ -1014,7 +1017,7 @@ delete_transient_in_khepri(FilterFun) ->
 foreach_transient(UpdateFun) ->
     rabbit_khepri:handle_fallback(
       #{mnesia => fun() -> foreach_transient_in_mnesia(UpdateFun) end,
-        khepri => fun() -> throw(not_implemented) end
+        khepri => fun() -> foreach_transient_in_khepri(UpdateFun) end
        }).
 
 foreach_transient_in_mnesia(UpdateFun) ->
@@ -1026,6 +1029,9 @@ foreach_transient_in_mnesia(UpdateFun) ->
               ok
       end).
 
+foreach_transient_in_khepri(_UpdateFun) ->
+    throw(not_implemented).
+
 %% -------------------------------------------------------------------
 %% foreach_durable().
 %% -------------------------------------------------------------------