from watchdog.observers import Observer
class DirTrigger(FileSystemEventHandler):
- COOL_TIME = 10
- MAX_TIME = 86400
- def __init__(self, dir_path):
+ def __init__(self, dir_path, cool_time, max_time):
self._got_event = False
self._last_event_time = 0.0
self._last_reset_time = 0.0
+ self._cool_time = cool_time
+ self._max_time = max_time
self._lock = threading.Lock()
self._observer = Observer()
self._observer.schedule(self, path=dir_path, recursive=True)
self._lock.acquire()
try:
return ( self._got_event and
- (time.time() - self._last_event_time > DirTrigger.COOL_TIME) ) or \
- time.time() - self._last_reset_time > DirTrigger.MAX_TIME
+ (time.time() - self._last_event_time > self._cool_time) ) or \
+ time.time() - self._last_reset_time > self._max_time
finally:
self._lock.release()