diff --git a/backend/bec_atlas/datasources/redis_datasource.py b/backend/bec_atlas/datasources/redis_datasource.py
index 0d91862..479ac42 100644
--- a/backend/bec_atlas/datasources/redis_datasource.py
+++ b/backend/bec_atlas/datasources/redis_datasource.py
@@ -22,16 +22,13 @@ def __init__(self, config: dict):
         password = config.get("password")
 
         try:
-            self.connector._redis_conn.auth(password, username=username)
+            self.connector.authenticate(username=username, password=password)
             self.reconfigured_acls = False
         except (AuthenticationError, ResponseError):
             self.setup_acls()
-            self.connector._redis_conn.auth(password, username=username)
+            self.connector.authenticate(username=username, password=password)
             self.reconfigured_acls = True
 
-        self.connector._redis_conn.connection_pool.connection_kwargs["username"] = username
-        self.connector._redis_conn.connection_pool.connection_kwargs["password"] = password
-
         if config.get("async_instance"):
             self.async_connector = config.get("async_instance")
         else: