From 5b5b76c53468f3a0eec399bbc43c2ce37acab3f4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lauri=20V=C3=B5sandi?= Date: Sun, 6 Nov 2022 21:59:51 +0200 Subject: [PATCH] Add cornercase handling for MODIFY --- log_shipper.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/log_shipper.py b/log_shipper.py index 310ba13..d45f396 100755 --- 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: