From 8976e25b7a70fda74f6fcf791dde50e74cc4fa99 Mon Sep 17 00:00:00 2001
From: EMQ-YangM <yangm@emqx.io>
Date: Wed, 26 Jan 2022 11:20:09 +0800
Subject: [PATCH] fix(emqx_resource_instance): create health_check process when
 create resources synchronously

---
 apps/emqx_resource/src/emqx_resource_instance.erl | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/apps/emqx_resource/src/emqx_resource_instance.erl b/apps/emqx_resource/src/emqx_resource_instance.erl
index 0cdeeae50..42819abd2 100644
--- a/apps/emqx_resource/src/emqx_resource_instance.erl
+++ b/apps/emqx_resource/src/emqx_resource_instance.erl
@@ -247,7 +247,12 @@ start_and_check(InstId, ResourceType, Config, Opts, Data) ->
             Data2 = Data#{state => ResourceState},
             ets:insert(emqx_resource_instance, {InstId, Data2}),
             case maps:get(async_create, Opts, false) of
-                false -> do_health_check(Data2);
+                false -> case do_health_check(Data2) of
+                            ok -> emqx_resource_health_check:create_checker(InstId,
+                                      maps:get(health_check_interval, Opts, 15000),
+                                      maps:get(health_check_timeout, Opts, 10000));
+                            {error, Reason} -> {error, Reason}
+                         end;
                 true -> emqx_resource_health_check:create_checker(InstId,
                             maps:get(health_check_interval, Opts, 15000),
                             maps:get(health_check_timeout, Opts, 10000))