@@ -17,9 +17,9 @@ def my_setup():
17
17
topo = Topo (topoStr )
18
18
logger = configureLogging (path , None )
19
19
prometheus_attrs = {'sensor' : 'GPFSFilesystem' , 'period' : 300 ,
20
- 'nsamples' : 300 , 'rawData' : True }
21
- pfilters = {'node' :'scale-16' , 'gpfs_filesystem_name' : 'afmCacheFS' }
22
- pquery_filters = [ f"{ k } ={ v } " for k , v in pfilters .items ()]
20
+ 'nsamples' : 300 , 'rawData' : True }
21
+ pfilters = {'node' : 'scale-16' , 'gpfs_filesystem_name' : 'afmCacheFS' }
22
+ pquery_filters = [f"{ k } ={ v } " for k , v in pfilters .items ()]
23
23
24
24
25
25
@with_setup (my_setup )
@@ -32,9 +32,9 @@ def test_case01():
32
32
query = request .get_zimon_query ()
33
33
query .includeDiskData = md_instance .includeDiskData .return_value
34
34
queryString = 'get -j {0} {1} group {2} bucket_size {3} {4}' .format (
35
- '' , '-z' , prometheus_attrs .get ('sensor' ),
36
- prometheus_attrs .get ('period' ),
37
- f"last { prometheus_attrs .get ('period' )} " )
35
+ '' , '-z' , prometheus_attrs .get ('sensor' ),
36
+ prometheus_attrs .get ('period' ),
37
+ f"last { prometheus_attrs .get ('period' )} " )
38
38
queryString += '\n '
39
39
assert "group" in query .__str__ ()
40
40
assert "last" in query .__str__ ()
@@ -53,9 +53,9 @@ def test_case02():
53
53
query = request .get_zimon_query ()
54
54
query .includeDiskData = md_instance .includeDiskData .return_value
55
55
queryString = 'get -j {0} {1} group {2} bucket_size {3} {4}' .format (
56
- '' , '' , prometheus_attrs .get ('sensor' ),
57
- prometheus_attrs .get ('period' ),
58
- f"last { prometheus_attrs .get ('nsamples' )} " )
56
+ '' , '' , prometheus_attrs .get ('sensor' ),
57
+ prometheus_attrs .get ('period' ),
58
+ f"last { prometheus_attrs .get ('nsamples' )} " )
59
59
queryString += '\n '
60
60
assert "group" in query .__str__ ()
61
61
assert "last" in query .__str__ ()
@@ -64,7 +64,7 @@ def test_case02():
64
64
65
65
@with_setup (my_setup )
66
66
def test_case03 ():
67
- prometheus_attrs .update ({'filters' : pfilters })
67
+ prometheus_attrs .update ({'filters' : pfilters })
68
68
with mock .patch ('source.collector.QueryPolicy.md' ) as md :
69
69
md_instance = md .return_value
70
70
md_instance .includeDiskData .return_value = False
@@ -73,9 +73,9 @@ def test_case03():
73
73
query = request .get_zimon_query ()
74
74
query .includeDiskData = md_instance .includeDiskData .return_value
75
75
queryString = 'get -j {0} {1} group {2} bucket_size {3} {4}' .format (
76
- '' , '-z' , prometheus_attrs .get ('sensor' ),
77
- prometheus_attrs .get ('period' ),
78
- f"last { prometheus_attrs .get ('period' )} " )
76
+ '' , '-z' , prometheus_attrs .get ('sensor' ),
77
+ prometheus_attrs .get ('period' ),
78
+ f"last { prometheus_attrs .get ('period' )} " )
79
79
queryString += ' from ' + "," .join (pquery_filters )
80
80
queryString += '\n '
81
81
assert "group" in query .__str__ ()
@@ -86,7 +86,7 @@ def test_case03():
86
86
87
87
@with_setup (my_setup )
88
88
def test_case04 ():
89
- prometheus_attrs .update ({'filters' : pfilters })
89
+ prometheus_attrs .update ({'filters' : pfilters })
90
90
prometheus_attrs .update ({'nsamples' : 1 , 'rawData' : False })
91
91
with mock .patch ('source.collector.QueryPolicy.md' ) as md :
92
92
md_instance = md .return_value
@@ -96,9 +96,9 @@ def test_case04():
96
96
query = request .get_zimon_query ()
97
97
query .includeDiskData = md_instance .includeDiskData .return_value
98
98
queryString = 'get -j {0} {1} group {2} bucket_size {3} {4}' .format (
99
- '' , '' , prometheus_attrs .get ('sensor' ),
100
- prometheus_attrs .get ('period' ),
101
- f"last { prometheus_attrs .get ('nsamples' )} " )
99
+ '' , '' , prometheus_attrs .get ('sensor' ),
100
+ prometheus_attrs .get ('period' ),
101
+ f"last { prometheus_attrs .get ('nsamples' )} " )
102
102
queryString += ' from ' + "," .join (pquery_filters )
103
103
queryString += '\n '
104
104
assert "group" in query .__str__ ()
@@ -115,7 +115,7 @@ def test_case05(col_md, sts_md, md):
115
115
sensor = prometheus_attrs .get ('sensor' )
116
116
period = prometheus_attrs .get ('period' )
117
117
logger = logging .getLogger (__name__ )
118
- prometheus_attrs .update ({'filters' : pfilters })
118
+ prometheus_attrs .update ({'filters' : pfilters })
119
119
prometheus_attrs .update ({'nsamples' : 1 , 'rawData' : False })
120
120
121
121
md_instance = md .return_value
@@ -139,4 +139,3 @@ def test_case05(col_md, sts_md, md):
139
139
assert collector .period == period
140
140
assert collector .request == request
141
141
assert collector .labels == topo .getSensorLabels (sensor )
142
-
0 commit comments