Call maybe_start_keeper for couch_epi_data_source
COUCHDB-2796
diff --git a/src/couch_epi_data_source.erl b/src/couch_epi_data_source.erl
index bbeed70..f44430d 100644
--- a/src/couch_epi_data_source.erl
+++ b/src/couch_epi_data_source.erl
@@ -54,6 +54,7 @@
}.
start_link(SubscriberApp, {epi_key, Key}, Src, Options) ->
+ maybe_start_keeper(Key),
{ok, Locator} = locate(SubscriberApp, Src),
gen_server:start_link(?MODULE, [SubscriberApp, Locator, Key, Options], []).
@@ -189,3 +190,7 @@
catch error:undef ->
[]
end.
+
+maybe_start_keeper(Key) ->
+ Handle = couch_epi_data_gen:get_handle(Key),
+ couch_epi_module_keeper:maybe_start_keeper(couch_epi_data_gen, Handle).
