@@ -2893,12 +2893,11 @@ class TestSSL:
2893
2893
appropriate port.
2894
2894
"""
2895
2895
2896
- CLIENT_CERT , CLIENT_KEY , CA_CERT = get_tls_certificates ("cluster" )
2897
-
2898
2896
@pytest_asyncio .fixture ()
2899
2897
def create_client (self , request : FixtureRequest ) -> Callable [..., RedisCluster ]:
2900
2898
ssl_url = request .config .option .redis_ssl_url
2901
2899
ssl_host , ssl_port = urlparse (ssl_url )[1 ].split (":" )
2900
+ self .client_cert , self .client_key , self .ca_cert = get_tls_certificates ("cluster" )
2902
2901
2903
2902
async def _create_client (mocked : bool = True , ** kwargs : Any ) -> RedisCluster :
2904
2903
if mocked :
@@ -3017,24 +3016,24 @@ async def test_validating_self_signed_certificate(
3017
3016
) -> None :
3018
3017
async with await create_client (
3019
3018
ssl = True ,
3020
- ssl_ca_certs = self .CA_CERT ,
3019
+ ssl_ca_certs = self .ca_cert ,
3021
3020
ssl_cert_reqs = "required" ,
3022
- ssl_certfile = self .CLIENT_CERT ,
3023
- ssl_keyfile = self .CLIENT_KEY ,
3021
+ ssl_certfile = self .client_cert ,
3022
+ ssl_keyfile = self .client_key ,
3024
3023
) as rc :
3025
3024
assert await rc .ping ()
3026
3025
3027
3026
async def test_validating_self_signed_string_certificate (
3028
3027
self , create_client : Callable [..., Awaitable [RedisCluster ]]
3029
3028
) -> None :
3030
- with open (self .CA_CERT ) as f :
3029
+ with open (self .ca_cert ) as f :
3031
3030
cert_data = f .read ()
3032
3031
3033
3032
async with await create_client (
3034
3033
ssl = True ,
3035
3034
ssl_ca_data = cert_data ,
3036
3035
ssl_cert_reqs = "required" ,
3037
- ssl_certfile = self .CLIENT_CERT ,
3038
- ssl_keyfile = self .CLIENT_KEY ,
3036
+ ssl_certfile = self .client_cert ,
3037
+ ssl_keyfile = self .client_key ,
3039
3038
) as rc :
3040
3039
assert await rc .ping ()
0 commit comments