feat(python): add username option into redisOpts (#2108)

taskforcesh · Aug 3, 2023 · d27f33e · d27f33e
1 parent 6fe67b4
commit d27f33e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/python/bullmq/redis_connection.py b/python/bullmq/redis_connection.py
@@ -26,10 +26,11 @@ def __init__(self, redisOpts: dict | str = {}):
             port = redisOpts.get("port") or 6379
             db = redisOpts.get("db") or 0
             password = redisOpts.get("password") or None
+            username = redisOpts.get("username") or None
 
             self.conn = redis.Redis(
                 host=host, port=port, db=db, password=password, decode_responses=True,
-                retry=retry, retry_on_error=retry_errors)
+                retry=retry, retry_on_error=retry_errors, username=username)
         else:
             self.conn = redis.from_url(redisOpts, decode_responses=True, retry=retry,
                 retry_on_error=retry_errors)