diff --git a/config/services.go b/config/services.go index 67aa7f04b..441ad0887 100644 --- a/config/services.go +++ b/config/services.go @@ -394,8 +394,12 @@ func splitBroadcastClientApis(apis []string) []broadcastclient.ArcClientConfig { } func loadTaskManager(appConfig *AppConfig, options []bux.ClientOps) []bux.ClientOps { + ops := []taskmanager.TasqOps{} + if appConfig.TaskManager.Factory == taskmanager.FactoryRedis { + ops = append(ops, taskmanager.WithRedis(appConfig.Cache.Redis.URL)) + } options = append(options, bux.WithTaskqConfig( - taskmanager.DefaultTaskQConfig(TaskManagerQueueName, taskmanager.WithRedis(appConfig.Cache.Redis.URL)), + taskmanager.DefaultTaskQConfig(TaskManagerQueueName, ops...), )) return options }