23
23
from influxdb import InfluxDBClient
24
24
from influxdb .exceptions import InfluxDBClientError
25
25
26
- from influxdb .tests import skipIfPYpy , using_pypy , skipServerTests
26
+ from influxdb .tests import skip_if_pypy , using_pypy , skip_server_tests
27
27
from influxdb .tests .server_tests .base import ManyTestCasesWithServerMixin
28
28
from influxdb .tests .server_tests .base import SingleTestCaseWithServerMixin
29
29
@@ -82,15 +82,15 @@ def point(series_name, timestamp=None, tags=None, **fields):
82
82
]
83
83
84
84
if not using_pypy :
85
- dummy_pointDF = {
85
+ dummy_point_df = {
86
86
"measurement" : "cpu_load_short" ,
87
87
"tags" : {"host" : "server01" ,
88
88
"region" : "us-west" },
89
89
"dataframe" : pd .DataFrame (
90
90
[[0.64 ]], columns = ['value' ],
91
91
index = pd .to_datetime (["2009-11-10T23:00:00Z" ]))
92
92
}
93
- dummy_pointsDF = [{
93
+ dummy_points_df = [{
94
94
"measurement" : "cpu_load_short" ,
95
95
"tags" : {"host" : "server01" , "region" : "us-west" },
96
96
"dataframe" : pd .DataFrame (
@@ -120,7 +120,7 @@ def point(series_name, timestamp=None, tags=None, **fields):
120
120
]
121
121
122
122
123
- @skipServerTests
123
+ @skip_server_tests
124
124
class SimpleTests (SingleTestCaseWithServerMixin , unittest .TestCase ):
125
125
"""Define the class of simple tests."""
126
126
@@ -267,7 +267,7 @@ def test_invalid_port_fails(self):
267
267
InfluxDBClient ('host' , '80/redir' , 'username' , 'password' )
268
268
269
269
270
- @skipServerTests
270
+ @skip_server_tests
271
271
class CommonTests (ManyTestCasesWithServerMixin , unittest .TestCase ):
272
272
"""Define a class to handle common tests for the server."""
273
273
@@ -293,15 +293,15 @@ def test_write_points(self):
293
293
"""Test writing points to the server."""
294
294
self .assertIs (True , self .cli .write_points (dummy_point ))
295
295
296
- @skipIfPYpy
296
+ @skip_if_pypy
297
297
def test_write_points_DF (self ):
298
298
"""Test writing points with dataframe."""
299
299
self .assertIs (
300
300
True ,
301
301
self .cliDF .write_points (
302
- dummy_pointDF ['dataframe' ],
303
- dummy_pointDF ['measurement' ],
304
- dummy_pointDF ['tags' ]
302
+ dummy_point_df ['dataframe' ],
303
+ dummy_point_df ['measurement' ],
304
+ dummy_point_df ['tags' ]
305
305
)
306
306
)
307
307
@@ -342,7 +342,7 @@ def test_write_points_check_read_DF(self):
342
342
rsp = self .cliDF .query ('SELECT * FROM cpu_load_short' )
343
343
assert_frame_equal (
344
344
rsp ['cpu_load_short' ],
345
- dummy_pointDF ['dataframe' ]
345
+ dummy_point_df ['dataframe' ]
346
346
)
347
347
348
348
# Query with Tags
@@ -351,7 +351,7 @@ def test_write_points_check_read_DF(self):
351
351
assert_frame_equal (
352
352
rsp [('cpu_load_short' ,
353
353
(('host' , 'server01' ), ('region' , 'us-west' )))],
354
- dummy_pointDF ['dataframe' ]
354
+ dummy_point_df ['dataframe' ]
355
355
)
356
356
357
357
def test_write_multiple_points_different_series (self ):
@@ -407,21 +407,21 @@ def test_write_multiple_points_different_series_DF(self):
407
407
for i in range (2 ):
408
408
self .assertIs (
409
409
True , self .cliDF .write_points (
410
- dummy_pointsDF [i ]['dataframe' ],
411
- dummy_pointsDF [i ]['measurement' ],
412
- dummy_pointsDF [i ]['tags' ]))
410
+ dummy_points_df [i ]['dataframe' ],
411
+ dummy_points_df [i ]['measurement' ],
412
+ dummy_points_df [i ]['tags' ]))
413
413
time .sleep (1 )
414
414
rsp = self .cliDF .query ('SELECT * FROM cpu_load_short' )
415
415
416
416
assert_frame_equal (
417
417
rsp ['cpu_load_short' ],
418
- dummy_pointsDF [0 ]['dataframe' ]
418
+ dummy_points_df [0 ]['dataframe' ]
419
419
)
420
420
421
421
rsp = self .cliDF .query ('SELECT * FROM memory' )
422
422
assert_frame_equal (
423
423
rsp ['memory' ],
424
- dummy_pointsDF [1 ]['dataframe' ]
424
+ dummy_points_df [1 ]['dataframe' ]
425
425
)
426
426
427
427
def test_write_points_batch (self ):
@@ -786,7 +786,7 @@ def test_query_multiple_series(self):
786
786
self .cli .write_points (pts )
787
787
788
788
789
- @skipServerTests
789
+ @skip_server_tests
790
790
class UdpTests (ManyTestCasesWithServerMixin , unittest .TestCase ):
791
791
"""Define a class to test UDP series."""
792
792
0 commit comments