diff --git a/authentik/root/settings.py b/authentik/root/settings.py index 11d847b6ce..4870b278a5 100644 --- a/authentik/root/settings.py +++ b/authentik/root/settings.py @@ -196,8 +196,10 @@ if CONFIG.get_bool("redis.tls", False): _redis_protocol_prefix = "rediss://" _redis_celery_tls_requirements = f"?ssl_cert_reqs={CONFIG.get('redis.tls_reqs')}" _redis_url = ( - f"{_redis_protocol_prefix}:" - f"{quote_plus(CONFIG.get('redis.password'))}@{quote_plus(CONFIG.get('redis.host'))}:" + f"{_redis_protocol_prefix}" + f"{quote_plus(CONFIG.get('redis.username'))}:" + f"{quote_plus(CONFIG.get('redis.password'))}@" + f"{quote_plus(CONFIG.get('redis.host'))}:" f"{CONFIG.get_int('redis.port')}" ) diff --git a/internal/outpost/proxyv2/application/session.go b/internal/outpost/proxyv2/application/session.go index b30934fb42..a889eefc2f 100644 --- a/internal/outpost/proxyv2/application/session.go +++ b/internal/outpost/proxyv2/application/session.go @@ -32,8 +32,8 @@ func (a *Application) getStore(p api.ProxyOutpostConfig, externalHost *url.URL) } if a.isEmbedded { client := redis.NewClient(&redis.Options{ - Addr: fmt.Sprintf("%s:%d", config.Get().Redis.Host, config.Get().Redis.Port), - // Username: config.Get().Redis.Password, + Addr: fmt.Sprintf("%s:%d", config.Get().Redis.Host, config.Get().Redis.Port), + Username: config.Get().Redis.Username, Password: config.Get().Redis.Password, DB: config.Get().Redis.DB, }) diff --git a/lifecycle/system_migrations/to_0_13_authentik.py b/lifecycle/system_migrations/to_0_13_authentik.py index b621859d7c..c56d3b2d1f 100644 --- a/lifecycle/system_migrations/to_0_13_authentik.py +++ b/lifecycle/system_migrations/to_0_13_authentik.py @@ -116,6 +116,7 @@ class Migration(BaseMigration): host=CONFIG.get("redis.host"), port=6379, db=db, + username=CONFIG.get("redis.username"), password=CONFIG.get("redis.password"), ) redis.flushall()