From: Trenton H <797416+stumpylog@users.noreply.github.com> Date: Wed, 20 Sep 2023 21:04:42 +0000 (-0700) Subject: Handle when INotify fails to import but the polling is set to 0 still (#4230) X-Git-Tag: v2.0.0-beta.1~97 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=085e6da1f2d3f4d8f64a40bf35f72420659fa526;p=thirdparty%2Fpaperless-ngx.git Handle when INotify fails to import but the polling is set to 0 still (#4230) --- diff --git a/src/documents/management/commands/document_consumer.py b/src/documents/management/commands/document_consumer.py index 085c180aef..0cc4dc3ef8 100644 --- a/src/documents/management/commands/document_consumer.py +++ b/src/documents/management/commands/document_consumer.py @@ -245,6 +245,8 @@ class Command(BaseCommand): if settings.CONSUMER_POLLING == 0 and INotify: self.handle_inotify(directory, recursive, options["testing"]) else: + if INotify is None and settings.CONSUMER_POLLING == 0: # pragma: no cover + logger.warn("Using polling as INotify import failed") self.handle_polling(directory, recursive, options["testing"]) logger.debug("Consumer exiting.") @@ -257,8 +259,14 @@ class Command(BaseCommand): timeout = self.testing_timeout_s logger.debug(f"Configuring timeout to {timeout}s") + polling_interval = settings.CONSUMER_POLLING + if polling_interval == 0: # pragma: no cover + # Only happens if INotify failed to import + logger.warn("Using polling of 10s, consider settng this") + polling_interval = 10 + with ThreadPoolExecutor(max_workers=4) as pool: - observer = PollingObserver(timeout=settings.CONSUMER_POLLING) + observer = PollingObserver(timeout=polling_interval) observer.schedule(Handler(pool), directory, recursive=recursive) observer.start() try: