fixing #17 - at_eof fails

fixing #17 - at_eof fails is there is no temp file.
thanos · Nov 1, 2016 · 0f02f69 · 0f02f69
1 parent e829b0f
commit 0f02f69
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/src/tailchaser/tailer.py b/src/tailchaser/tailer.py
@@ -100,10 +100,15 @@ def filter(self, record):
         return True
 
     def at_eof(self, tmp_file, is_backfill_file_info):
-        if is_backfill_file_info:
-            is_backfill, (file_tailed, (fid, mtime, offset)) = is_backfill_file_info
-            if is_backfill and tmp_file != file_tailed:
-                os.unlink(tmp_file)
+        try:
+            if is_backfill_file_info:
+                is_backfill, (file_tailed, (fid, mtime, offset)) = is_backfill_file_info
+                if is_backfill and tmp_file != file_tailed:
+                    if os.path.exists(tmp_file):
+                        os.unlink(tmp_file)
+        except (IOError, OSError):
+            log.warning("at_eof failed to remove: %s", tmp_file)
+
 
     def run(self, source_pattern, receiver=None):
         self.startup()