feat: connect to redis sentinel for redis queue

frappe/utils/redis_queue.py

@@ -17,6 +17,20 @@ def add_user(self, username, password=None):
 
 	@classmethod
 	def get_connection(cls, username=None, password=None):
+		if frappe.conf.redis_queue_sentinel_enabled:
+			from frappe.utils.redis_wrapper import get_sentinel_connection
+
+			sentinels = [tuple(node.split(":")) for node in frappe.conf.get("redis_queue_sentinels", [])]
+			sentinel = get_sentinel_connection(
+				sentinels=sentinels,
+				sentinel_username=frappe.conf.get("redis_queue_sentinel_username"),
+				sentinel_password=frappe.conf.get("redis_queue_sentinel_password"),
+				master_username=frappe.conf.get("redis_queue_master_username", username),
+				master_password=frappe.conf.get("redis_queue_master_password", password),
+			)
+			conn = sentinel.master_for(frappe.conf.get("redis_queue_master_service"))
+			conn.ping()
+			return conn
 		conn = redis.from_url(frappe.conf.redis_queue, username=username, password=password)
 		conn.ping()
 		return conn