When using django-huey, the consumer is able to correctly find the registered tasks, however when running the Django server and trying to enqueue a task, I get an "HueyException not found in TaskRegistry" error. From doing wayy too much debugging, I finally tracked this down to the fact that the huey package initializes itself with RegistryA, and then django_huey initializes itself with a separate RegistryB. So when trying to enqueue a task, it attempts to find the task in RegistryA which is empty, because all of the tasks are in RegistryB.

I use import django_huey as huey everywhere, and then use @huey.task(queue="test"), but I'm still getting this error. I'm not sure what I'm doing wrong 😞

I use djangohuey --queue [name of queue] to run consumer, this runs my task, but the django-huey-monitor does not track the tasks, or are not created in the huey_monitor database tables. Which configuration am I missing?

Settings:

DJANGO_HUEY = {
    'default': 'xxx',
    'queues': {
        'xxx': {
            'huey_class': 'huey.SqliteHuey',
            'name': 'xxx_tasks',
            'consumer': {
                'workers': 4,
                'worker_type': 'thread',
            },
        },
        'yyy': { 
            'huey_class': 'huey.SqliteHuey',
            'name': 'yyy_tasks',
            'consumer': {
                'workers': 2,
                'worker_type': 'thread',
            },
        }
    }
}

Exception raised:

huey.exceptions.ConfigurationError: "redis" python module not found, cannot use Redis storage backend. Run "pip install redis" to install.

redis should be optional.

Is there a way to configure the djangohuey settings, so that a specific worker is assigned to a specific queue? At the moment, I implement different queues with different number of workers in each consumer, but anytime a worker is free, it is taken on by any of the queue tasks that are waiting. what I want is for example: worker1 listen to only queue_a and worker2&worker3 listen to queue_b, regardless of which worker is free. Is this possible? Here are my settings:

DJANGO_HUEY = {
    'default': 'first', #this name must match with any of the queues defined below.
    'queues': {
        'queue_a': {
            'huey_class': 'huey.RedisHuey',
            'name': 'tasks_a',
            "immediate": False,
            'results': True,
            'blocking': True,
            'connection': {
                    'host': 'localhost',
                    'port': 6379,
                    'db': 0,
                    'connection_pool': None,
                    'read_timeout': 1,
                    'url': None,  
                },
            'consumer': {
                'workers': 1,
                'worker_type': 'thread',
            },
        },
        'queue_b': {
            'huey_class': 'huey.RedisHuey',
            'name': 'tasks_b',
            "immediate": False,
            'blocking': True,
            
            'consumer': {
                'workers': 2,
                'worker_type': 'thread',
            },
        },
    }
}