Log ouput Issues

[cd-home]

INFO: 2022/05/25 17:52:39 worker.go:58 Launching a worker with the following settings: INFO: 2022/05/25 17:52:39 worker.go:59 - Broker: :// INFO: 2022/05/25 17:52:39 worker.go:61 - DefaultQueue: machinery_tasks INFO: 2022/05/25 17:52:39 worker.go:65 - ResultBackend: :// INFO: 2022/05/25 17:52:39 goredis.go:110 [*] Waiting for messages. To exit press CTRL+C

TIPS: if use iface mode cnf := &config.Config{ DefaultQueue: "machinery_tasks", ResultsExpireIn: 3600, Redis: &config.RedisConfig{ MaxIdle: 3, IdleTimeout: 240, ReadTimeout: 15, WriteTimeout: 15, ConnectTimeout: 15, NormalTasksPollPeriod: 1000, DelayedTasksPollPeriod: 500, }, } broker := redisbroker.NewGR(cnf, []string{"127.0.0.1:6379"}, 0) backend := redisbackend.NewGR(cnf, []string{"127.0.0.1:6379"}, 0) lock := eagerlock.New() server := machinery.NewServer(cnf, broker, backend, lock) server.RegisterTask("sun", Sum)

worker := server.NewWorker("worker", 0)
worker.Launch()

------ LOG ----------- // LaunchAsync is a non blocking version of Launch func (worker *Worker) LaunchAsync(errorsChan chan<- error) { cnf := worker.server.GetConfig() broker := worker.server.GetBroker()

// Log some useful information about worker configuration
log.INFO.Printf("Launching a worker with the following settings:")
log.INFO.Printf("- Broker: %s", RedactURL(cnf.Broker))
if worker.Queue == "" {
	log.INFO.Printf("- DefaultQueue: %s", cnf.DefaultQueue)
} else {
	log.INFO.Printf("- CustomQueue: %s", worker.Queue)
}
log.INFO.Printf("- ResultBackend: %s", RedactURL(cnf.ResultBackend))

...... }

in fact, backedn and broker read from conf

[cd-home]

func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker { ....... cnf.Broker = strings.Join(ropt.Addrs, ", ") .... }