Search code examples
pythondjangodjango-celery

What is causing this djcelery error: NotRegistered?

Running this script in a django shell:

import processors.topics.tasks as t
t.test.delay()

Gives this error:

NotRegistered: 'processors.topics.tasks.test'

The weird thing is that chorus.processors.topics.tasks.test is definitely included in the [Tasks] printout when I run

python celeryd --verbosity=2 --loglevel=INFO --purge

Why am I getting the error?

Solution

  • It has to do with the way you are importing the task for example, You are importing the task from the project instead of the app, chorus.processors.topics tasks instead of processors.topics.tasks. This creates problems for Celery, since the name will be different in the client and the server.

    Here are the docs that relate to the following issue