From 2bfcd0c523ea6fa1e8556bf5eb25958e7da12293 Mon Sep 17 00:00:00 2001 From: karlhjm Date: Tue, 21 Nov 2023 20:28:28 +0800 Subject: [PATCH] fix: CANNOT connet to Redis with special password #2893 --- internal/job/job.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/job/job.go b/internal/job/job.go index 58756f4ece3..fdfb59e9f99 100644 --- a/internal/job/job.go +++ b/internal/job/job.go @@ -21,6 +21,7 @@ import ( "encoding/json" "errors" "fmt" + "net/url" "reflect" "strings" "time" @@ -64,9 +65,9 @@ func New(cfg *Config, queue Queue) (*Job, error) { } server, err := machinery.NewServer(&machineryv1config.Config{ - Broker: fmt.Sprintf("redis://%s@%s/%d", cfg.Password, strings.Join(cfg.Addrs, ","), cfg.BrokerDB), + Broker: fmt.Sprintf("redis://%s@%s/%d", url.QueryEscape(cfg.Password), strings.Join(cfg.Addrs, ","), cfg.BrokerDB), DefaultQueue: queue.String(), - ResultBackend: fmt.Sprintf("redis://%s@%s/%d", cfg.Password, strings.Join(cfg.Addrs, ","), cfg.BackendDB), + ResultBackend: fmt.Sprintf("redis://%s@%s/%d", url.QueryEscape(cfg.Password), strings.Join(cfg.Addrs, ","), cfg.BackendDB), ResultsExpireIn: DefaultResultsExpireIn, Redis: &machineryv1config.RedisConfig{ MasterName: cfg.MasterName,