我正在使用Django定期芹菜任務。我曾經在我的應用程序/文件tasks.py以下任務:芹菜節拍隊列包括過時的任務
@periodic_task(run_every=timedelta(minutes=2))
def stuff():
...
但是,現在這個任務已經從我的應用程序/ tasks.py文件中刪除。但是,我總是看到調用此任務在我的芹菜日誌:
[2013-05-21 07:08:37,963: ERROR/MainProcess] Received unregistered task of type u'app.tasks.stuff'.
看來,我用不更新其隊列中的芹菜節拍調度。這是如何在我的項目/ settings.py文件中定義調度程序:
CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler"
重新啓動芹菜工沒有幫助。僅供參考,我使用Redis經紀人。
我該如何清除或更新芹菜節拍隊列,以便舊的任務不會發送到我的芹菜工?
我認爲你也必須刪除該日程安排的數據庫條目。你可以從django管理員那裏這樣做。 – Ngenator
嗨裏吉斯,你是否設法解決這個問題。我有同樣的問題。 @Ngenator - 你的解決方案是 –
這個問題可能發生在redis服務器上。由於芹菜任務是一個被推入redis服務器的pickle對象,redis保留了過時的任務。重新啓動redis服務器,或調用任務的清除功能。 –