From d5ec76295455105fc5a9d21a77d6a16af06b9ddc Mon Sep 17 00:00:00 2001 From: jonaswinkler Date: Thu, 26 Nov 2020 18:55:05 +0100 Subject: [PATCH] couple changes to the consumer. --- src/documents/management/commands/document_consumer.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/documents/management/commands/document_consumer.py b/src/documents/management/commands/document_consumer.py index 4bfd78e8f..c25d0cfa9 100644 --- a/src/documents/management/commands/document_consumer.py +++ b/src/documents/management/commands/document_consumer.py @@ -95,14 +95,8 @@ class Command(BaseCommand): def handle(self, *args, **options): directory = options["directory"] - logging.getLogger(__name__).info( - f"Starting document consumer at {directory}") - for entry in os.scandir(directory): - if entry.is_file(): - async_task("documents.tasks.consume_file", - entry.path, - task_name=os.path.basename(entry.path)[:100]) + _consume(entry.path) if options["oneshot"]: return