python - Celery beat queue includes obsolete tasks -
i'm using periodic celery tasks django. used have following task in app/tasks.py file:
@periodic_task(run_every=timedelta(minutes=2)) def stuff(): ...
but task has been removed app/tasks.py file. however, keep seeing call task in celery logs:
[2013-05-21 07:08:37,963: error/mainprocess] received unregistered task of type u'app.tasks.stuff'.
it seems celery beat scheduler use not update queue. how scheduler defined in project/settings.py file:
celerybeat_scheduler = "djcelery.schedulers.databasescheduler"
restarting celery worker not help. fyi, use redis broker.
how can either clear or update celery beat queue older tasks not sent celery worker?
install django-celery.
as cited, project not needed use celery yet need enable admin interface @ /admin/djcelery/
managing periodic tasks. there won't no registered or periodic tasks.
restart beat , check table periodic tasks again. beat have added existing scheduled tasks table interval or crontab defined in settings or decorators. there can delete unwanted tasks.
update: celery4, it's recommended use package. https://github.com/celery/django-celery-beat
Comments
Post a Comment