PR #335 добавил task, но celery_app.py имеет explicit `include=[]` (а не autodiscover), поэтому worker не импортировал новый модуль и не зарегистрировал task name. apply_async из admin endpoint падал с KeyError: 'tasks.scrape_kn_catalog_objects.scrape_kn_catalog_objects'. One-line add to include list. |
||
|---|---|---|
| .. | ||
| tasks | ||
| __init__.py | ||
| beat_schedule.py | ||
| celery_app.py | ||
| lifecycle.py | ||