|
10 | 10 | class RedisTimeSeriesTest(TestCase):
|
11 | 11 | def setUp(self):
|
12 | 12 | global rts
|
13 |
| - rts = RedisTimeSeries(port=port) |
| 13 | + rts = RedisTimeSeries(host='200.1.3.7', port=port) |
14 | 14 | rts.flushdb()
|
15 | 15 |
|
16 | 16 | def testCreate(self):
|
@@ -154,20 +154,20 @@ def testMGet(self):
|
154 | 154 | rts.create(1, labels={'Test':'This'})
|
155 | 155 | rts.create(2, labels={'Test':'This', 'Taste':'That'})
|
156 | 156 | act_res = rts.mget(['Test=This'])
|
157 |
| - exp_res = [{'1': [{}, None, None]}, {'2': [{}, None, None]}] |
| 157 | + exp_res = {'1': ({}, None, None), '2': ({}, None, None)} |
158 | 158 | self.assertEqual(act_res, exp_res)
|
159 | 159 | rts.add(1, '*', 15)
|
160 | 160 | rts.add(2, '*', 25)
|
161 | 161 | res = rts.mget(['Test=This'])
|
162 |
| - self.assertEqual(15, res[0]['1'][2]) |
163 |
| - self.assertEqual(25, res[1]['2'][2]) |
| 162 | + self.assertEqual(15, res['1'][2]) |
| 163 | + self.assertEqual(25, res['2'][2]) |
164 | 164 | res = rts.mget(['Taste=That'])
|
165 |
| - self.assertEqual(25, res[0]['2'][2]) |
| 165 | + self.assertEqual(25, res['2'][2]) |
166 | 166 |
|
167 | 167 | # test with_labels
|
168 |
| - self.assertEqual({}, res[0]['2'][0]) |
| 168 | + self.assertEqual({}, res['2'][0]) |
169 | 169 | res = rts.mget(['Taste=That'], with_labels=True)
|
170 |
| - self.assertEqual({'Taste': 'That', 'Test': 'This'}, res[0]['2'][0]) |
| 170 | + self.assertEqual({'Taste': 'That', 'Test': 'This'}, res['2'][0]) |
171 | 171 |
|
172 | 172 | def testInfo(self):
|
173 | 173 | '''Test TS.INFO calls'''
|
|
0 commit comments