File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change 13
13
limitations under the License."""
14
14
15
15
import time
16
- import Queue
16
+ from six . moves import queue
17
17
18
18
from carbon import state
19
19
from carbon .cache import MetricCache
53
53
54
54
class TagQueue (object ):
55
55
def __init__ (self , maxsize = 0 , update_interval = 1 ):
56
- self .add_queue = Queue .Queue (maxsize )
57
- self .update_queue = Queue .Queue (maxsize )
56
+ self .add_queue = queue .Queue (maxsize )
57
+ self .update_queue = queue .Queue (maxsize )
58
58
self .update_interval = update_interval
59
59
self .update_counter = 0
60
60
61
61
def add (self , metric ):
62
62
try :
63
63
self .add_queue .put_nowait (metric )
64
- except Queue .Full :
64
+ except queue .Full :
65
65
pass
66
66
67
67
def update (self , metric ):
68
68
self .update_counter = self .update_counter % self .update_interval + 1
69
69
if self .update_counter == 1 :
70
70
try :
71
71
self .update_queue .put_nowait (metric )
72
- except Queue .Full :
72
+ except queue .Full :
73
73
pass
74
74
75
75
def getbatch (self , maxsize = 1 ):
76
76
batch = []
77
77
while len (batch ) < maxsize :
78
78
try :
79
79
batch .append (self .add_queue .get_nowait ())
80
- except Queue .Empty :
80
+ except queue .Empty :
81
81
break
82
82
while len (batch ) < maxsize :
83
83
try :
84
84
batch .append (self .update_queue .get_nowait ())
85
- except Queue .Empty :
85
+ except queue .Empty :
86
86
break
87
87
return batch
88
88
You can’t perform that action at this time.
0 commit comments