Skip to content

Commit c503d57

Browse files
Make sure definition import work pool is started before actual import boot step
1 parent 4e97013 commit c503d57

File tree

1 file changed

+15
-14
lines changed

1 file changed

+15
-14
lines changed

src/rabbit.erl

Lines changed: 15 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,21 @@
101101
{requires, pre_boot},
102102
{enables, external_infrastructure}]}).
103103

104+
-rabbit_boot_step({definition_import_worker_pool,
105+
[{description, "dedicated worker pool for definition import"},
106+
{mfa, {rabbit_definitions, boot, []}},
107+
{requires, external_infrastructure},
108+
{enables, load_core_definitions}]}).
109+
110+
%% We want to A) make sure we apply definitions before the node begins serving
111+
%% traffic and B) in fact do it before empty_db_check (so the defaults will not
112+
%% get created if we don't need 'em).
113+
-rabbit_boot_step({load_core_definitions,
114+
[{description, "imports definitions"},
115+
{mfa, {rabbit_definitions, maybe_load_definitions, []}},
116+
{requires, [recovery, definition_import_worker_pool]},
117+
{enables, empty_db_check}]}).
118+
104119
-rabbit_boot_step({external_infrastructure,
105120
[{description, "external infrastructure ready"}]}).
106121

@@ -188,15 +203,6 @@
188203
{requires, [core_initialized]},
189204
{enables, routing_ready}]}).
190205

191-
%% We want to A) make sure we apply definitions before the node begins serving
192-
%% traffic and B) in fact do it before empty_db_check (so the defaults will not
193-
%% get created if we don't need 'em).
194-
-rabbit_boot_step({load_core_definitions,
195-
[{description, "imports definitions"},
196-
{mfa, {rabbit_definitions, maybe_load_definitions, []}},
197-
{requires, recovery},
198-
{enables, empty_db_check}]}).
199-
200206
-rabbit_boot_step({empty_db_check,
201207
[{description, "empty DB check"},
202208
{mfa, {?MODULE, maybe_insert_default_data, []}},
@@ -236,11 +242,6 @@
236242
[{description, "ready to communicate with peers and clients"},
237243
{requires, [core_initialized, recovery, routing_ready]}]}).
238244

239-
-rabbit_boot_step({definition_import_worker_pool,
240-
[{description, "dedicated worker pool for definition import"},
241-
{mfa, {rabbit_definitions, boot, []}},
242-
{requires, pre_flight}]}).
243-
244245
-rabbit_boot_step({cluster_name,
245246
[{description, "sets cluster name if configured"},
246247
{mfa, {rabbit_nodes, boot, []}},

0 commit comments

Comments
 (0)