@@ -53,10 +53,10 @@ def factory(username):
5353
5454 yield factory
5555 try :
56- current_user = await r .client_info ()
56+ client_info = await r .client_info ()
5757 except exceptions .NoPermissionError :
58- current_user = {}
59- if "default" != current_user .get ("user" ):
58+ client_info = {}
59+ if "default" != client_info .get ("user" , " " ):
6060 await r .auth ("" , "default" )
6161 for username in usernames :
6262 await r .acl_deluser (username )
@@ -691,28 +691,34 @@ async def test_config_get_for_modules(self, r: redis.Redis):
691691 assert "search-timeout" in search_module_configs
692692
693693 ts_module_configs = await r .config_get ("ts-*" )
694- assert "ts-num-threads " in ts_module_configs
694+ assert "ts-retention-policy " in ts_module_configs
695695
696696 bf_module_configs = await r .config_get ("bf-*" )
697- assert "bf-initial-size " in bf_module_configs
697+ assert "bf-error-rate " in bf_module_configs
698698
699699 cf_module_configs = await r .config_get ("cf-*" )
700- assert "cf-max-iterations " in cf_module_configs
700+ assert "cf-initial-size " in cf_module_configs
701701
702702 @pytest .mark .redismod
703703 @skip_if_server_version_lt ("7.9.0" )
704704 async def test_config_set_for_search_module (self , r : redis .Redis ):
705- search_timeout_initial = (await r .config_get ())["search-timeout" ]
706- search_timeout_new = int (search_timeout_initial ) + 100
707-
708- assert await r .config_set ("search-timeout" , search_timeout_new )
709- assert (
710- int ((await r .config_get ("search-*" ))["search-timeout" ])
711- == search_timeout_new
712- )
713- assert (
714- int ((await r .ft ().config_get ("TIMEOUT" ))[b"TIMEOUT" ]) == search_timeout_new
715- )
705+ config = await r .config_get ("*" )
706+ initial_default_search_dialect = config ["search-default-dialect" ]
707+ try :
708+ default_dialect_new = "3"
709+ assert await r .config_set ("search-default-dialect" , default_dialect_new )
710+ assert (await r .config_get ("*" ))[
711+ "search-default-dialect"
712+ ] == default_dialect_new
713+ assert (
714+ (await r .ft ().config_get ("*" ))[b"DEFAULT_DIALECT" ]
715+ ).decode () == default_dialect_new
716+ except AssertionError as ex :
717+ raise ex
718+ finally :
719+ assert await r .config_set (
720+ "search-default-dialect" , initial_default_search_dialect
721+ )
716722 with pytest .raises (exceptions .ResponseError ):
717723 await r .config_set ("search-max-doctablesize" , 2000000 )
718724
0 commit comments