rabbit_khepri: Remove serial file during reset

rabbitmq · Nov 15, 2024 · 05717cc · 05717cc
1 parent e41d766
commit 05717cc
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/deps/rabbit/src/rabbit_khepri.erl b/deps/rabbit/src/rabbit_khepri.erl
@@ -591,7 +591,10 @@ reset() ->
             %% Restart it.
             ok = setup(),
             ok = khepri_cluster:reset(?RA_CLUSTER_NAME),
-            ok = khepri:stop(?RA_CLUSTER_NAME);
+            ok = khepri:stop(?RA_CLUSTER_NAME),
+
+            _ = file:delete(rabbit_guid:filename()),
+            ok;
         true ->
             throw({error, rabbitmq_unexpectedly_running})
     end.
@@ -605,7 +608,10 @@ force_reset() ->
             DataDir = maps:get(data_dir, ra_system:fetch(coordination)),
             ok = ra_system:ensure_ra_system_stopped(coordination),
             ok = rabbit_file:recursive_delete(
-                   filelib:wildcard(DataDir ++ "/*"));
+                   filelib:wildcard(DataDir ++ "/*")),
+
+            _ = file:delete(rabbit_guid:filename()),
+            ok;
         true ->
             throw({error, rabbitmq_unexpectedly_running})
     end.