Seler: auto odkrycie nie znajdzie modułu zadań w aplikacji

Question

Mam następującą konfigurację z zainstalowanym świeżego selera i django 1.4:

settings.py:

import djcelery 
djcelery.setup_loader() 

BROKER_HOST = 'localhost' 
BROKER_PORT = 5672 
BROKER_USER = 'user' 
BROKER_PASSWORD = 'password' 
BROKER_VHOST = 'test' 

[...] 

INSTALLED_APPS = [ 
    'django.contrib.auth', 
    'django.contrib.admin', 
    'django.contrib.contenttypes', 
    'django.contrib.sessions', 
    'django.contrib.sites', 
    'django.contrib.staticfiles', 
    'djcelery', 
    'south', 
    'compressor', 
    'testapp', 
] 

testapp/tasks.py:

from celery.task import task 

@task() 
def add(x, y): 
    return x + y 

Dostarczenie wiadomości do selerad działa dobrze, ale zadanie jest zawsze niezarejestrowane (więc automatyczne odnajdywanie nie działa tutaj poprawnie). Tylko jeśli zaimportuję moduł zadań w tasks/__init__.py, zadanie zostanie znalezione i będę mógł go użyć.

Również dokumentacja była nieco myląca co do importu dekoratora, ale myślę, że teraz jest właściwa.

Gdzie jest błąd w mojej konfiguracji?

Answer 1

To był błąd w django-selekcji 2.5.4, proszę uaktualnić do wersji 2.5.5!

Answer 2

Dodaj CELERY_IMPORTS do settings.py:

CELERY_IMPORTS = ('testapp.tasks',) 

zaimportować wszystkie zadania testapp.tasks.__init__ pliku

Następnie Seler zaimportuje wszystkie zadania z folderu testapp.tasks i wymienić je, ponieważ są one

Answer 3

Miałem ten sam problem z django 1.4.1 selerem 3.0.9 i naprawiłem go, nazywając zadanie.

@Task() -> @Task (name = 'testapp.tasks.add')

Answer 4

jestem całkiem pewny, trzeba importować "Seler aplikacji instancji" i zadeklarować zadanie takiego:

from project_name.celery import app 

@app.task 
def video_process_task(video_id): 
    pass 

uwaga, że ​​jest to plik celery.py w/folderu PROJECT_NAME project_dir, który stwierdzi wystąpienie seler, tak:

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

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project_name.settings') 
app = Celery('project_name') 
app.config_from_object('django.conf:settings') 
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

zgodnie z instrukcją w official documentation.

również trzeba zarejestrować zadanie, w jednym z tych trzech sposobów:

• zmienna CELERY_IMPORTS w settings.py plik Django projektu jak w dgel za odpowiedź
• przechodzącej bind=True do dekoratora jak: @app.task(bind=True)
• jeśli ustawisz automatyczne wykrywanie dla selera, tak jak dzieje się to powyżej w linii app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) , każdy folder aplikacji Django może zawierać plik tasks.py, a zadeklarowane w nim zadania zostaną automatycznie zarejestrowane

pamiętać, że zmiany do zadania wymagają selera RESTART odniosły skutek

Answer 5

dla każdego, kto szuka tu natyka podobnego rozwiązania problemu.

W moim przypadku przełączenie ze starych baz modułów INSTALLED_APPS na nową konfigurację opartą na AppConfig.

Nowe aplikacje powinny unikać default_app_config. Zamiast tego powinny one wymagać, aby przerywana ścieżka do odpowiedniej podklasy AppConfig była jawnie skonfigurowana w INSTALLED_APPS.

Aby rozwiązać ten problem należy zmienić sposób karmienia pakietów selera, jak podano tu w 2248 Celery issue:

from django.apps import apps 
app.autodiscover_tasks(lambda: [n.name for n in apps.get_app_configs()] 

Zamiast the old Celery 3 way:

app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)