@@ -38,7 +38,7 @@ def test_redis_host(redis_container: RedisContainer) -> str:
3838
3939@pytest .fixture (scope = 'session' )
4040def test_redis_port (redis_container : RedisContainer ) -> int :
41- return redis_container .get_exposed_port (redis_container . port_to_expose )
41+ return redis_container .get_exposed_port (6379 )
4242
4343
4444@pytest .fixture (scope = 'session' )
@@ -58,7 +58,7 @@ async def arq_redis(test_redis_host: str, test_redis_port: int):
5858
5959 yield redis_
6060
61- await redis_ .close (close_connection_pool = True )
61+ await redis_ .aclose (close_connection_pool = True )
6262
6363
6464@pytest .fixture
@@ -72,7 +72,7 @@ async def arq_redis_msgpack(test_redis_host: str, test_redis_port: int):
7272 )
7373 await redis_ .flushall ()
7474 yield redis_
75- await redis_ .close (close_connection_pool = True )
75+ await redis_ .aclose (close_connection_pool = True )
7676
7777
7878@pytest .fixture
@@ -87,7 +87,7 @@ async def arq_redis_retry(test_redis_host: str, test_redis_port: int):
8787 )
8888 await redis_ .flushall ()
8989 yield redis_
90- await redis_ .close (close_connection_pool = True )
90+ await redis_ .aclose (close_connection_pool = True )
9191
9292
9393@pytest .fixture
@@ -140,7 +140,7 @@ async def create_pool_(settings, *args, **kwargs):
140140
141141 yield create_pool_
142142
143- await asyncio .gather (* [p .close (close_connection_pool = True ) for p in pools ])
143+ await asyncio .gather (* [p .aclose (close_connection_pool = True ) for p in pools ])
144144
145145
146146@pytest .fixture (name = 'cancel_remaining_task' )
0 commit comments