@@ -47,6 +47,12 @@ def check_version_2(env):
47
47
return True
48
48
return False
49
49
50
+ def check_edge (env ):
51
+ v = env .execute_command ('MODULE LIST' )[0 ][3 ]
52
+ if v is "999999" :
53
+ return True
54
+ return False
55
+
50
56
class RedisSearchTestCase (ModuleTestCase ('../module.so' )):
51
57
52
58
def createIndex (self , client , num_docs = 100 , definition = None ):
@@ -230,6 +236,8 @@ def testPayloads(self):
230
236
conn = self .redis ()
231
237
232
238
with conn as r :
239
+ if not check_edge (r ):
240
+ return
233
241
# Creating a client with a given index name
234
242
client = Client ('idx' , port = conn .port )
235
243
client .redis .flushdb ()
@@ -241,11 +249,10 @@ def testPayloads(self):
241
249
q = Query ("foo bar" ).with_payloads ()
242
250
res = client .search (q )
243
251
self .assertEqual (2 , res .total )
244
- self .assertEqual ('doc2' , res .docs [0 ].id )
245
-
246
- self .assertEqual ('doc1' , res .docs [1 ].id )
247
- self .assertEqual ('foo baz' , res .docs [1 ].payload )
248
- self .assertIsNone (res .docs [0 ].payload )
252
+ self .assertEqual ('doc1' , res .docs [0 ].id )
253
+ self .assertEqual ('doc2' , res .docs [1 ].id )
254
+ self .assertEqual ('foo baz' , res .docs [0 ].payload )
255
+ self .assertIsNone (res .docs [1 ].payload )
249
256
250
257
def testScores (self ):
251
258
conn = self .redis ()
@@ -803,8 +810,11 @@ def testGet(self):
803
810
804
811
def testConfig (self ):
805
812
client = self .getCleanClient ('idx' )
813
+ if not check_edge (client .redis ):
814
+ return
806
815
self .assertTrue (client .config_set ('TIMEOUT' , '100' ))
807
- self .assertFalse (client .config_set ('TIMEOUT' , "null" ))
816
+ with self .assertRaises (redis .ResponseError ) as error :
817
+ client .config_set ('TIMEOUT' , "null" )
808
818
res = client .config_get ('*' )
809
819
self .assertEqual ('100' , res ['TIMEOUT' ])
810
820
res = client .config_get ('TIMEOUT' )
0 commit comments