使用数据库调度程序的Django Celery Beat?任务似乎从未完成

问题描述 投票:0回答:1

我需要在Django Admin的Django Celery Beat软件包https://django-celery-beat.readthedocs.io/en/latest/中使用DatabaseScheduler的助手。

我想使用Django Celery Beat执行以下功能:

@shared_task
def count_widgets():
    return Widget.objects.count()

我已在Django Admin中设置了定期任务,正在使用celapp.tasks.count_widgets任务(已注册),并将Cronschedule设置为可以运行。任务开始在celery服务器上运行,但从未完成

在RabbitMQ中,当任务开始运行但没有完成消息时,我得到以下信息:INFO/MainProcess] Writing entries...INFO/MainProcess] Scheduler: Sending due task New Tester (celapp.tasks.count_widgets)INFO/MainProcess] Writing entries...

我在做什么错?

并在底部

django django-celery celerybeat django-celery-beat
1个回答
0
投票

您能否为任务共享您的crontab对象?也许您已经设置好在几秒钟内运行。

© www.soinside.com 2019 - 2024. All rights reserved.