Merge pull request #40 from RedisAI/fix.ft.create

Ensure all primaries receive the FT.CREATE due to 'missing index error on querying' in multi-node scenarios
RedisAI · Jun 17, 2023 · f92c29b · f92c29b
2 parents 0bcd51c + fb02421
commit f92c29b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ann_benchmarks/algorithms/redisearch.py b/ann_benchmarks/algorithms/redisearch.py
@@ -38,7 +38,7 @@ def fit(self, X, offset=0, limit=None, hybrid_buckets = None):
             elif self.algo == "FLAT":
                 args.extend(['vector', 'VECTOR', self.algo, '6', 'TYPE', 'FLOAT32', 'DIM', len(X[0]), 'DISTANCE_METRIC', self.metric])
             print("Calling FT.CREATE", *args)
-            self.redis.execute_command('FT.CREATE', *args,  target_nodes='random')
+            self.redis.execute_command('FT.CREATE', *args,  target_nodes='primaries')
         except Exception as e:
             if 'Index already exists' not in str(e):
                 raise