diff --git a/task_processor/management/commands/runprocessor.py b/task_processor/management/commands/runprocessor.py index fed66d5..cc08b88 100644 --- a/task_processor/management/commands/runprocessor.py +++ b/task_processor/management/commands/runprocessor.py @@ -2,6 +2,7 @@ from argparse import ArgumentParser from django.core.management import BaseCommand +from django.utils.module_loading import autodiscover_modules from gunicorn.config import Config from task_processor.threads import TaskRunner, TaskRunnerCoordinator @@ -60,6 +61,8 @@ def handle(self, *args, **options): logger.debug("Config: %s", config) + autodiscover_modules("tasks") + coordinator = TaskRunnerCoordinator(config=config) coordinator.start()