scheduled-tasks - 显示 KeyError: 'schedules.tasks.run' 同时为定期任务运行 django celery

Question

我创建了一个基于类的定期任务，使用 djcelery 向客户端发送电子邮件。当从 shell 调用任务时，它正在执行操作并发送电子邮件，但是在使用 crontab 时，我将 KeyError 设为“Schedule.tasks.run”。我添加了以下设置并创建了任务：

设置.py

import os
import djcelery

djcelery.setup_loader()

BROKER_URL = 'django://'

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'

CELERYBEAT_SCHEDULE = {
"runs-every-30-seconds": {
    "task": "schedules.tasks.EndingDrawslotScheduler.run",
    "schedule": timedelta(seconds=30),
    "args": (16, 16)
},
}
app.conf.timezone = 'UTC'

INSTALLED_APPS = ('djcelery',
'kombu.transport.django',)

错误信息：

邮件正文的完整内容是：

{'utc': True, 'callbacks': None, 'id': '6ad19ff8-9825-4d54-a8b2-0a8322fc9fb1', 
'args': [], 'taskset': None, 'retries': 0, 'timelimit': (None, None), 
'kwargs': {}, 'expires': None, 'errbacks': None, 'chord': None, 'task': 
'schedules.tasks.run', 'eta': None} (262b)

回溯（最近一次通话最后）：

文件“/home/s/proj/env/lib/python3.5/site-packages/celery/worker/consumer.py”，第 465 行，on_task_received strategy[type_](message, body, KeyError: 'schedules.tasks 。跑'