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", dir_path, str(e))
def stop(self):
self._observer.stop()