12
12
"""
13
13
import datetime
14
14
import os
15
- import six
16
15
17
16
from DIRAC import gLogger , S_OK , S_ERROR , gConfig
18
17
from DIRAC .Core .DISET .RequestHandler import RequestHandler
@@ -37,12 +36,12 @@ class MonitoringHandler(RequestHandler):
37
36
"""
38
37
39
38
__reportRequestDict = {
40
- "typeName" : six . string_types ,
41
- "reportName" : six . string_types ,
39
+ "typeName" : str ,
40
+ "reportName" : str ,
42
41
"startTime" : Time ._allDateTypes ,
43
42
"endTime" : Time ._allDateTypes ,
44
43
"condDict" : dict ,
45
- "grouping" : six . string_types ,
44
+ "grouping" : str ,
46
45
"extraArgs" : dict ,
47
46
}
48
47
@@ -73,7 +72,7 @@ def initializeHandler(cls, serviceInfo):
73
72
74
73
return S_OK ()
75
74
76
- types_listUniqueKeyValues = [six . string_types ]
75
+ types_listUniqueKeyValues = [str ]
77
76
78
77
def export_listUniqueKeyValues (self , typeName ):
79
78
"""
@@ -87,7 +86,7 @@ def export_listUniqueKeyValues(self, typeName):
87
86
# NOTE: we can apply some policies if it will be needed!
88
87
return self .__db .getKeyValues (typeName )
89
88
90
- types_listReports = [six . string_types ]
89
+ types_listReports = [str ]
91
90
92
91
def export_listReports (self , typeName ):
93
92
"""
@@ -257,7 +256,7 @@ def export_getReport(self, reportRequest):
257
256
reportRequest ["generatePlot" ] = False
258
257
return reporter .generate (reportRequest , self .getRemoteCredentials ())
259
258
260
- types_addMonitoringRecords = [six . string_types , list ]
259
+ types_addMonitoringRecords = [str , list ]
261
260
262
261
def export_addMonitoringRecords (self , monitoringtype , data ):
263
262
"""
@@ -275,7 +274,7 @@ def export_addMonitoringRecords(self, monitoringtype, data):
275
274
gLogger .debug ("addMonitoringRecords:" , prefix )
276
275
return self .__db .bulk_index (prefix , data )
277
276
278
- types_addRecords = [six . string_types , six . string_types , list ]
277
+ types_addRecords = [str , str , list ]
279
278
280
279
def export_addRecords (self , indexname , monitoringType , data ):
281
280
"""
@@ -293,7 +292,7 @@ def export_addRecords(self, indexname, monitoringType, data):
293
292
gLogger .debug ("Mapping:" , mapping )
294
293
return self .__db .bulk_index (indexname , data , mapping )
295
294
296
- types_deleteIndex = [six . string_types ]
295
+ types_deleteIndex = [str ]
297
296
298
297
def export_deleteIndex (self , indexName ):
299
298
"""
@@ -307,7 +306,7 @@ def export_deleteIndex(self, indexName):
307
306
gLogger .debug ("delete index:" , indexName )
308
307
return self .__db .deleteIndex (indexName )
309
308
310
- types_getLastDayData = [six . string_types , dict ]
309
+ types_getLastDayData = [str , dict ]
311
310
312
311
def export_getLastDayData (self , typeName , condDict ):
313
312
"""
@@ -322,7 +321,7 @@ def export_getLastDayData(self, typeName, condDict):
322
321
323
322
return self .__db .getLastDayData (typeName , condDict )
324
323
325
- types_getLimitedDat = [six . string_types , dict , int ]
324
+ types_getLimitedDat = [str , dict , int ]
326
325
327
326
def export_getLimitedData (self , typeName , condDict , size ):
328
327
"""
@@ -339,7 +338,7 @@ def export_getLimitedData(self, typeName, condDict, size):
339
338
"""
340
339
return self .__db .getLimitedData (typeName , condDict , size )
341
340
342
- types_getDataForAGivenPeriod = [six . string_types , dict , six . string_types , six . string_types ]
341
+ types_getDataForAGivenPeriod = [str , dict , str , str ]
343
342
344
343
def export_getDataForAGivenPeriod (self , typeName , condDict , initialDate = "" , endDate = "" ):
345
344
"""
@@ -358,7 +357,7 @@ def export_getDataForAGivenPeriod(self, typeName, condDict, initialDate="", endD
358
357
"""
359
358
return self .__db .getDataForAGivenPeriod (typeName , condDict , initialDate , endDate )
360
359
361
- types_put = [list , six . string_types ]
360
+ types_put = [list , str ]
362
361
363
362
def export_put (self , recordsToInsert , monitoringType ):
364
363
"""
0 commit comments