Use ssl for sentinel

falkordb/falkordb.py

@@ -98,8 +98,8 @@
                            protocol=protocol)
 
         if Is_Sentinel(conn):
-            self.sentinel, self.service_name = Sentinel_Conn(conn)
-            conn = self.sentinel.master_for(self.service_name)
+            self.sentinel, self.service_name = Sentinel_Conn(conn, ssl)
+            conn = self.sentinel.master_for(self.service_name, ssl=ssl)
 
         self.connection      = conn
         self.flushdb         = conn.flushdb

falkordb/sentinel.py

@@ -6,7 +6,7 @@
     return "redis_mode" in info and info["redis_mode"] == "sentinel"
 
 # create a sentinel connection from a Redis connection
-def Sentinel_Conn(conn):
+def Sentinel_Conn(conn, ssl):
     # collect masters
     masters = conn.sentinel_masters()
 
@@ -41,6 +41,8 @@
         sentinel_kwargs['username'] = connection_kwargs['username']
     if 'password' in connection_kwargs:
         sentinel_kwargs['password'] = connection_kwargs['password']
+    if ssl:
+        sentinel_kwargs['ssl'] = True
 
     return (Sentinel(sentinels_conns, sentinel_kwargs=sentinel_kwargs, **connection_kwargs), service_name)
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "FalkorDB"
-version = "1.0.5"
+version = "1.0.6"
 description = "Python client for interacting with FalkorDB database"
 authors = ["FalkorDB inc <info@falkordb.com>"]