我需要在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...
我在做什么错?
并在底部
您能否为任务共享您的crontab对象?也许您已经设置好在几秒钟内运行。