From 917ee62f81847cac6d46f124dfc61dce966b7da9 Mon Sep 17 00:00:00 2001 From: Jonas Winkler Date: Thu, 12 Nov 2020 09:30:04 +0100 Subject: [PATCH] fixes #30 --- .../management/commands/document_consumer.py | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/src/documents/management/commands/document_consumer.py b/src/documents/management/commands/document_consumer.py index 93ad6947c..a90fd53ed 100644 --- a/src/documents/management/commands/document_consumer.py +++ b/src/documents/management/commands/document_consumer.py @@ -20,8 +20,21 @@ class Handler(FileSystemEventHandler): def __init__(self, consumer): self.consumer = consumer + def _consume(self, file): + if os.path.isfile(file): + try: + self.consumer.try_consume_file(file) + except Exception as e: + logging.getLogger(__name__).error("Error while consuming document: {}".format(e)) + def on_created(self, event): - self.consumer.try_consume_file(event.src_path) + self._consume(event.src_path) + + def on_modified(self, event): + self._consume(event.src_path) + + def on_moved(self, event): + self._consume(event.src_path) class Command(BaseCommand):