我正在使用celery和celery-beat不使用Django,我有一個任務需要celery-beat在運行時修改計劃?,F在我有以下代碼(名為 的模塊celery_tasks):# __init__.pyfrom .celery import app as celery_app__all__ = ['celery_app']#celery.pyfrom celery import Celeryimport configcelery_config = config.get_celery_config()app = Celery( __name__, include=[ 'celery_tasks.tasks', ],)app.conf.update(celery_config)# tasks.pyfrom celery_tasks import celery_appfrom celery import shared_task@shared_taskdef start_game(): celery_app.conf.beat_schedule = { 'process_round': { 'task': 'celery_tasks.tasks.process_round', 'schedule': 5, }, }我從celery以下命令開始:celery worker -A celery_tasks -E -l info --beatstart_game正常執行和存在,但beatprocess_round任務從不運行。如何強制重新加載節拍計劃(重新啟動所有工人似乎不是一個好主意)?
2 回答

守著一只汪
TA貢獻1872條經驗 獲得超4個贊
使用 schedule config 似乎也是個壞主意。如果最初 process_round 任務將處于活動狀態并檢查游戲是否未開始,那么什么都不做。
添加回答
舉報
0/150
提交
取消