add username when create redis client
@@ -58,6 +58,7 @@ type job struct {
func New(cfg *config.Config, resource resource.Resource) (Job, error) {
redisConfig := &internaljob.Config{
Addrs: cfg.Job.Redis.Addrs,
+ Username: cfg.Job.Redis.Username,
Password: cfg.Job.Redis.Password,
BrokerDB: cfg.Job.Redis.BrokerDB,
BackendDB: cfg.Job.Redis.BackendDB,
