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