Skip to content

Commit 937af18

Browse files
committed
rabbit_khepri: Add projection registration to khepri_db ff enable function
1 parent b345193 commit 937af18

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,8 @@
8787

8888
-module(rabbit_khepri).
8989

90+
-feature(maybe_expr, enable).
91+
9092
-include_lib("kernel/include/logger.hrl").
9193
-include_lib("stdlib/include/assert.hrl").
9294

@@ -1495,9 +1497,10 @@ get_feature_state(Node) ->
14951497
%% @private
14961498

14971499
khepri_db_migration_enable(#{feature_name := FeatureName}) ->
1498-
case sync_cluster_membership_from_mnesia(FeatureName) of
1499-
ok -> migrate_mnesia_tables(FeatureName);
1500-
Error -> Error
1500+
maybe
1501+
ok ?= sync_cluster_membership_from_mnesia(FeatureName),
1502+
ok ?= register_projections(),
1503+
migrate_mnesia_tables(FeatureName)
15011504
end.
15021505

15031506
%% @private

0 commit comments

Comments
 (0)