clean registry only once after migration

[photosort.git] / src / dirtrigger.py

diff --git a/src/dirtrigger.py b/src/dirtrigger.py
index 90473366a952acc446edb25cd6ad2231b79b3a5e..1ef7e8bbf7e90cd8b1fe5114be48bfb28aab04ff 100644 (file)
--- a/src/dirtrigger.py
+++ b/src/dirtrigger.py
@@ -7,22 +7,21 @@ from watchdog.observers import Observer
 class DirTrigger(FileSystemEventHandler):
 
     def __init__(self, dir_path, cool_time, max_time):
 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._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._lock = threading.Lock()

+        self._observer = Observer()
+        self._observer.schedule(self, path=dir_path, recursive=True)

 
 

+    def start(self):

         try:
         try:

-            self._observer = Observer()
-            self._observer.schedule(self, path=dir_path, recursive=True)
+            self._observer.start()

         except Exception as e:
         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()
 
     def stop(self):
         self._observer.stop()