@@ -812,22 +812,23 @@ def test_chunked_response(self):
812
812
"http://localhost:8086/query" ,
813
813
text = example_response
814
814
)
815
- response = list ( self .cli .query ('show series limit 4 offset 0' ,
816
- chunked = True , chunk_size = 4 ) )
815
+ response = self .cli .query ('show series limit 4 offset 0' ,
816
+ chunked = True , chunk_size = 4 )
817
817
self .assertTrue (len (response ) == 4 )
818
- self .assertEqual (response [0 ].raw , ResultSet (
819
- {"statement_id" : 0 ,
820
- "series" : [{"name" : "cpu" ,
821
- "columns" : ["fieldKey" , "fieldType" ],
822
- "values" : [["value" , "integer" ]]}],
823
- "partial" : True }
824
- ).raw )
825
- self .assertEqual (response [3 ].raw , ResultSet (
826
- {"statement_id" : 0 ,
827
- "series" : [{"name" : "memory" ,
828
- "columns" : ["fieldKey" , "fieldType" ],
829
- "values" : [["value" , "integer" ]]}]}
830
- ).raw )
818
+ self .assertEqual (response .__repr__ (), ResultSet (
819
+ {'series' : [{'values' : [['value' , 'integer' ]],
820
+ 'name' : 'cpu' ,
821
+ 'columns' : ['fieldKey' , 'fieldType' ]},
822
+ {'values' : [['value' , 'integer' ]],
823
+ 'name' : 'iops' ,
824
+ 'columns' : ['fieldKey' , 'fieldType' ]},
825
+ {'values' : [['value' , 'integer' ]],
826
+ 'name' : 'load' ,
827
+ 'columns' : ['fieldKey' , 'fieldType' ]},
828
+ {'values' : [['value' , 'integer' ]],
829
+ 'name' : 'memory' ,
830
+ 'columns' : ['fieldKey' , 'fieldType' ]}]}
831
+ ).__repr__ ())
831
832
832
833
833
834
class FakeClient (InfluxDBClient ):
0 commit comments