Skip to content

Commit a771263

Browse files
committed
rabbit_khepri: Add projection registration to khepri_db ff enable fun
1 parent ffec9f7 commit a771263

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

@@ -1518,9 +1520,10 @@ get_feature_state(Node) ->
15181520
%% @private
15191521

15201522
khepri_db_migration_enable(#{feature_name := FeatureName}) ->
1521-
case sync_cluster_membership_from_mnesia(FeatureName) of
1522-
ok -> migrate_mnesia_tables(FeatureName);
1523-
Error -> Error
1523+
maybe
1524+
ok ?= sync_cluster_membership_from_mnesia(FeatureName),
1525+
ok ?= register_projections(),
1526+
migrate_mnesia_tables(FeatureName)
15241527
end.
15251528

15261529
%% @private

0 commit comments

Comments
 (0)