fix redis cluster materialization (#1968)

Signed-off-by: qooba <dev@qooba.net>
feast-dev · Oct 25, 2021 · c59ec58 · c59ec58
1 parent 9359441
commit c59ec58
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/python/feast/infra/online_stores/redis.py b/sdk/python/feast/infra/online_stores/redis.py
@@ -142,7 +142,7 @@ def _get_client(self, online_store_config: RedisOnlineStoreConfig):
             startup_nodes, kwargs = self._parse_connection_string(
                 online_store_config.connection_string
             )
-            if online_store_config.type == RedisType.redis_cluster:
+            if online_store_config.redis_type == RedisType.redis_cluster:
                 kwargs["startup_nodes"] = startup_nodes
                 self._client = RedisCluster(**kwargs)
             else: