11import logging
22import requests
33import datetime
4- import sys
54from time import sleep
65from typing import Optional
76
@@ -22,8 +21,6 @@ def __init__(self, testing=False):
2221 self .client = ActivityWatchClient ("aw-watcher-table" , testing = testing )
2322 self .bucket_id = "{}_{}" .format (self .client .client_name , self .client .client_hostname )
2423
25- self .last_table_height = None
26-
2724 def run (self ):
2825 logger .info ("aw-watcher-table started" )
2926
@@ -40,8 +37,7 @@ def ping(self, table_height: Optional[int]):
4037 event = Event (
4138 timestamp = datetime .datetime .now (datetime .timezone .utc ),
4239 data = {
43- "status" : self .get_table_status (table_height ),
44- "table_height" : table_height
40+ "status" : self .get_table_status (table_height )
4541 }
4642 )
4743 # 10 seconds request timeout
@@ -50,16 +46,7 @@ def ping(self, table_height: Optional[int]):
5046 def get_table_height (self ) -> Optional [int ]:
5147 try :
5248 r = requests .get (f'http://{ self .settings .ip } /measure' )
53- table_height = r .json ()['table_height' ]
54-
55- if self .last_table_height is None :
56- self .last_table_height = table_height
57- return table_height
58-
59- if abs (self .last_table_height - table_height ) < self .settings .min_change_height :
60- table_height = self .last_table_height
61-
62- return table_height
49+ return r .json ()['table_height' ]
6350
6451 except Exception as ex :
6552 logger .warning (f'aw-watcher-table: Measurement failed! Please make sure http://{ self .settings .ip } /measure '
0 commit comments