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

Popular posts from this blog

blackberry 10 - how to add multiple markers on the google map just by url? -

php - guestbook returning database data to flash -

delphi - Dynamic file type icon -