Do not use drop_interval
This commit is contained in:
parent
ba41cecb72
commit
e1eecea36d
|
@ -144,7 +144,6 @@ class ThreadedSegment(MultiRunnedThread):
|
||||||
|
|
||||||
|
|
||||||
class KwThreadedSegment(ThreadedSegment):
|
class KwThreadedSegment(ThreadedSegment):
|
||||||
drop_interval = 10 * 60
|
|
||||||
update_first = True
|
update_first = True
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
|
@ -198,7 +197,7 @@ class KwThreadedSegment(ThreadedSegment):
|
||||||
self.new_queries = []
|
self.new_queries = []
|
||||||
|
|
||||||
for key, (last_query_time, state) in queries.items():
|
for key, (last_query_time, state) in queries.items():
|
||||||
if last_query_time < monotonic() < last_query_time + self.drop_interval:
|
if last_query_time < monotonic() < last_query_time + self.interval:
|
||||||
updates[key] = (last_query_time, state)
|
updates[key] = (last_query_time, state)
|
||||||
else:
|
else:
|
||||||
self.update_one(crashed, updates, key)
|
self.update_one(crashed, updates, key)
|
||||||
|
|
Loading…
Reference in New Issue