Django芹菜周期性任务没有在上述crontab上运行

Question

我正在使用以下软件包。

celery==5.1.2
Django==3.1

我有2个定期芹菜任务，其中我希望第一个任务每15分钟运行一次，第二个任务每20分钟运行一次。但是问题在于，第一个任务是按时运行，而第二个任务未运行。

尽管我在控制台上收到一条消息：

Scheduler: Sending due task <task_name> (<task_name>)

但是该功能内部的日志并未在控制台上。

请找到以下文件

芹菜

from celery import Celery, Task
app = Celery('settings')
...

class PeriodicTask(Task):
    @classmethod
    def on_bound(cls, app):
        app.conf.beat_schedule[cls.name] = {
            "schedule": cls.run_every,
            "task": cls.name,
            "args": cls.args if hasattr(cls, "args") else (),
            "kwargs": cls.kwargs if hasattr(cls, "kwargs") else {},
            "options": cls.options if hasattr(cls, "options") else {}
        }

，

from celery.schedules import crontab
from settings.celery import app, PeriodicTask
...

@app.task(
    base=PeriodicTask,
    run_every=crontab(minute='*/15'),
    name='task1',
    options={'queue': 'queue_name'}
)
def task1():
    logger.info("task1 called")

@app.task(
    base=PeriodicTask,
    run_every=crontab(minute='*/20'),
    name='task2'
)
def task2():
    logger.info("task2 called")

。谢谢！

Answer 1

您是否启用了芹菜的登录方式。文档说，要记录您必须启用记录。这是文档的链接 celery docs 参考伐木部分。