fix: Cast port to int in ClusterNode connection string parsing (#352)

* fix: Cast port to int in ClusterNode connection string parsing

* fix: Strip scheme prefix if present

---------

Co-authored-by: omirandadev <oscarmiranda3100@gmail.com>

Author: omirandadev

sdk/python/feast/infra/online_stores/eg_valkey.py

@@ -216,10 +216,15 @@ def _parse_connection_string(connection_string: str):
         for Valkey Standalone:
             valkey_master:6379,db=0,ssl=true,password=...
         """
+        # Strip scheme prefix (e.g. valkey://, valkeys://) if present
+        if "://" in connection_string:
+            connection_string = connection_string.split("://", 1)[1]
         startup_nodes = [
-            dict(zip(["host", "port"], c.split(":")))
+            {"host": parts[0], "port": int(parts[1])}
             for c in connection_string.split(",")
             if "=" not in c
+            for parts in [c.split(":")]
+            if len(parts) == 2
         ]
         params = {}
         for c in connection_string.split(","):

sdk/python/feast/infra/online_stores/redis.py

@@ -208,10 +208,15 @@ def _parse_connection_string(connection_string: str):
         for Redis:
             redis_master:6379,db=0,ssl=true,password=...
         """
+        # Strip scheme prefix (e.g. redis://, rediss://) if present
+        if "://" in connection_string:
+            connection_string = connection_string.split("://", 1)[1]
         startup_nodes = [
-            dict(zip(["host", "port"], c.split(":")))
+            {"host": parts[0], "port": int(parts[1])}
             for c in connection_string.split(",")
             if "=" not in c
+            for parts in [c.split(":")]
+            if len(parts) == 2
         ]
         params = {}
         for c in connection_string.split(","):