From 62d3aecc0985e94eac3047f08ff40a4f6229e136 Mon Sep 17 00:00:00 2001 From: EMQ-YangM Date: Tue, 1 Mar 2022 14:20:04 +0800 Subject: [PATCH] fix(emqx_connector): add default Opts: '#{wait_connected => 1000}' --- apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl | 3 ++- apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl | 3 ++- apps/emqx_connector/test/emqx_connector_redis_SUITE.erl | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl b/apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl index b38cee3eb..6c5932b97 100644 --- a/apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl +++ b/apps/emqx_connector/test/emqx_connector_mysql_SUITE.erl @@ -68,7 +68,8 @@ perform_lifecycle_check(PoolName, InitialConfig) -> PoolName, ?CONNECTOR_RESOURCE_GROUP, ?MYSQL_RESOURCE_MOD, - CheckedConfig + CheckedConfig, + #{wait_connected => 1000} ), ?assertEqual(InitialStatus, connected), % Instance should match the state and status of the just started resource diff --git a/apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl b/apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl index 331283c59..25bf6bb06 100644 --- a/apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl +++ b/apps/emqx_connector/test/emqx_connector_pgsql_SUITE.erl @@ -68,7 +68,8 @@ perform_lifecycle_check(PoolName, InitialConfig) -> PoolName, ?CONNECTOR_RESOURCE_GROUP, ?PGSQL_RESOURCE_MOD, - CheckedConfig + CheckedConfig, + #{wait_connected => 1000} ), ?assertEqual(InitialStatus, connected), % Instance should match the state and status of the just started resource diff --git a/apps/emqx_connector/test/emqx_connector_redis_SUITE.erl b/apps/emqx_connector/test/emqx_connector_redis_SUITE.erl index 45fc17d9a..787872d3c 100644 --- a/apps/emqx_connector/test/emqx_connector_redis_SUITE.erl +++ b/apps/emqx_connector/test/emqx_connector_redis_SUITE.erl @@ -83,7 +83,8 @@ perform_lifecycle_check(PoolName, InitialConfig, RedisCommand) -> PoolName, ?CONNECTOR_RESOURCE_GROUP, ?REDIS_RESOURCE_MOD, - CheckedConfig + CheckedConfig, + #{wait_connected => 1000} ), ?assertEqual(InitialStatus, connected), % Instance should match the state and status of the just started resource