diff --git a/internal/job/job.go b/internal/job/job.go
index 137419afe..e260d0e34 100644
--- a/internal/job/job.go
+++ b/internal/job/job.go
@@ -53,16 +53,6 @@ func New(cfg *Config, queue Queue) (*Job, error) {
 	// Set logger
 	machineryv1log.Set(&MachineryLogger{})
 
-	if err := ping(&redis.UniversalOptions{
-		Addrs:      cfg.Addrs,
-		MasterName: cfg.MasterName,
-		Username:   cfg.Username,
-		Password:   cfg.Password,
-		DB:         cfg.BrokerDB,
-	}); err != nil {
-		return nil, err
-	}
-
 	if err := ping(&redis.UniversalOptions{
 		Addrs:      cfg.Addrs,
 		MasterName: cfg.MasterName,
@@ -98,8 +88,7 @@ func New(cfg *Config, queue Queue) (*Job, error) {
 }
 
 func ping(options *redis.UniversalOptions) error {
-	client := redis.NewUniversalClient(options)
-	return client.Ping(context.Background()).Err()
+	return redis.NewUniversalClient(options).Ping(context.Background()).Err()
 }
 
 func (t *Job) RegisterJob(namedJobFuncs map[string]any) error {