class DirTrigger(FileSystemEventHandler):
def __init__(self, dir_path, cool_time, max_time):
+ self._dir_path = dir_path
+ self._cool_time = cool_time
+ self._max_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)
+ def start(self):
try:
- self._observer = Observer()
- self._observer.schedule(self, path=dir_path, recursive=True)
+ self._observer.start()
except Exception as e:
- logging.error("Error creating file observer for %s: %s", dir_path, str(e))
- raise e
-
- def start(self):
- self._observer.start()
+ logging.warning("Error starting file observer for %s: %s", self._dir_path, str(e))
def stop(self):
self._observer.stop()