Add cornercase handling for MODIFY

2022-11-06 21:59:51 +02:00 · 2022-11-06 21:59:51 +02:00 · 5b5b76c534
parent 6e96d40584
commit 5b5b76c534
1 changed files with 3 additions and 2 deletions
--- a/log_shipper.py
+++ b/log_shipper.py
@ -377,8 +377,9 @@ async def watcher(loop, queue, coll):
            elif event.mask & Mask.MODIFY:
                counter_inotify_events.labels("modify").inc()
                log_file = log_files.get(str(event.path))
-                assert not log_file.done
-                log_file.poke()
+                if log_file:
+                    # TODO: Count cases where log_file is None
+                    log_file.poke()
            elif event.mask & Mask.IGNORED:
                counter_inotify_events.labels("ignored").inc()
            else: