From 452f6e766a59874840ff538a55c07545b96441a7 Mon Sep 17 00:00:00 2001
From: zhouzb <zhouzb@emqx.io>
Date: Thu, 13 Jan 2022 11:15:08 +0800
Subject: [PATCH] fix: return error when parse failed

---
 apps/emqx_connector/src/emqx_connector_pgsql.erl | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/apps/emqx_connector/src/emqx_connector_pgsql.erl b/apps/emqx_connector/src/emqx_connector_pgsql.erl
index 34f386282..90d1c207e 100644
--- a/apps/emqx_connector/src/emqx_connector_pgsql.erl
+++ b/apps/emqx_connector/src/emqx_connector_pgsql.erl
@@ -125,8 +125,10 @@ connect(Opts) ->
     NamedQueries = proplists:get_value(named_queries, Opts),
     case epgsql:connect(Host, Username, Password, conn_opts(Opts)) of
         {ok, Conn} ->
-            parse(Conn, NamedQueries),
-            {ok, Conn};
+            case parse(Conn, NamedQueries) of
+                ok -> {ok, Conn};
+                {error, Reason} -> {error, Reason}
+            end;
         {error, Reason} ->
             {error, Reason}
     end.