芹菜计划不触发任务，未报告错误

Question

我正在使用Django和芹菜：

在 celery.py，我有：

app.conf.beat_schedule = {
'send_notes_email': {
'task': 'send_notes_email_async',
'schedule': crontab(minute=3), 
},
}

任务设置如下：

@app.task(bind=True, name='send_notes_email_async', max_retries=3)
def send_notes_email_async():
print('a')
send_notes_email()

芹菜正在工作，识别任务，但 3 分钟后不触发。 也没有错误。 Redis 报告密钥 芹菜任务没有时间表

-------------- celery@WIN-U5VDSO5V1CK v4.2.1 (windowlicker)
---- **** -----
--- * ***  * -- Windows-7-6.1.7601-SP1
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         PH:0x3d2d128
- ** ---------- .> transport:   redis://localhost:6379//
- ** ---------- .> results:     redis://localhost:6379/
- *** --- * --- .> concurrency: 2 (eventlet)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
.> celery           exchange=celery(direct) key=celery
[tasks]
. send_notes_email_async

Answer 1

您的节拍计划配置是错误的，minute=3cronjob 意味着在第 3 分钟(01：03、02：03、03：03、04：03...(执行任务。

这是您想要的，每 3 分钟执行一次任务：

app.conf.beat_schedule = {
'send_notes_email': {
'task': 'send_notes_email_async',
'schedule': crontab(minute=*/3), 
},
}