Сельдерей с брокером Redis не может выполнить задачу Django

Question

В эти дни я изучаю Python(2.7)/Django(1.5), разрабатывая свой собственный клон Reddit (на Ubuntu 14.04 LTS). Я пытаюсь включить в микс Celery(3.1) с Redis, используя его для периодического запуска алгоритма ранжирования в качестве задачи (на моей локальной установке). Но, к сожалению, я не могу заставить эту простую задачу выполнить хотя бы один раз! Можете ли вы помочь мне определить, что я делаю неправильно?

Вот моя структура каталогов:

-unconnectedreddit (manage.py is here)
    -links (tasks.py, models.py, views.py, admin.py)
    -unconnectedreddit (celery.py, __init.py___, settings.py, urls.py)
        -static
        -templates

Celery.py:

from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'unconnectedreddit.settings')

app = Celery('unconnectedreddit', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0',include=['unconnectedreddit.links.tasks'])
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

app.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600,
)

if __name__ == '__main__':
    app.start()

Дополнения к settings.py заключаются в следующем. Обратите внимание, что я бегал migrate после добавления 'djcelery' в установленные приложения:

INSTALLED_APPS = ('djcelery',)

import djcelery
djcelery.setup_loader()

BROKER_URL = 'redis://localhost:6379/0'

CELERY_IMPORTS = ('links.tasks', )  

CELERY_ALWAYS_EAGER = False

CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_IGNORE_RESULT=True

from datetime import timedelta

CELERYBEAT_SCHEDULE = {
    'rank_all-every-30-seconds': {
        'task': 'tasks.rank_all',
        'schedule': timedelta(seconds=30),
    },
}

CELERY_TIMEZONE = 'UTC'

__init__.py:

from __future__ import absolute_import
from .celery import app as celery_app1

tasks.py:

import os
from unconnectedreddit import celery_app1
import time
from links.models import Link

@celery_app1.task
def rank_all():
    for link in Link.with_votes.all():
        link.set_rank() #ranks interesting 'links' submitted by users

Я запускаю эту команду в Терминале, чтобы запустить работника: celery -A unconnectedreddit worker -l info

Вывод, который я получаю, выглядит следующим образом:

 -------------- celery@has-VirtualBox v3.1.18 (Cipater)
---- **** ----- 
--- * ***  * -- Linux-3.16.0-30-generic-x86_64-with-Ubuntu-14.04-trusty
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> app:         unconnectedreddit:0x7f938b838910
- ** ---------- .> transport:   redis://localhost:6379/0
- ** ---------- .> results:     redis://localhost:6379/0
- *** --- * --- .> concurrency: 1 (prefork)
-- ******* ---- 
--- ***** ----- [queues]
 -------------- .> celery           exchange=celery(direct) key=celery


[tasks]
  . links.tasks.rank_all

[2015-06-04 12:01:17,083: INFO/MainProcess] Connected to redis://localhost:6379/0
[2015-06-04 12:01:17,098: INFO/MainProcess] mingle: searching for neighbors
[2015-06-04 12:01:18,107: INFO/MainProcess] mingle: all alone
/home/has/.virtualenvs/unconnectedreddit/local/lib/python2.7/site-packages/celery/fixups/django.py:265: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
  warnings.warn('Using settings.DEBUG leads to a memory leak, never '

[2015-06-04 12:01:18,136: WARNING/MainProcess] /home/has/.virtualenvs/unconnectedreddit/local/lib/python2.7/site-packages/celery/fixups/django.py:265: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
  warnings.warn('Using settings.DEBUG leads to a memory leak, never '

[2015-06-04 12:01:18,137: WARNING/MainProcess] celery@has-VirtualBox ready.

Вот и все. Я намеревался периодически запускать эту задачу через каждые 30 секунд (см. Мой CELERYBEAT_SCHEDULE). Но мой код не приводит к его выполнению ни разу - рейтинг моего клона reddit не меняется вообще. Может ли какой-нибудь эксперт указать, что мне не хватает в этой настройке?

Answer 1

Неверное название задачи. Это было исправлено путем изменения декоратора задачи на @celery_app1.task(name='tasks.rank_all') и настроить мой график ритма, чтобы включить правильное имя:

CELERYBEAT_SCHEDULE = {
    'tasks.rank_all': {
        'task': 'tasks.rank_all',
        'schedule': timedelta(seconds=30),
    },
}