celerybeatredis
celerybeatredis copied to clipboard
kongluoxing
celery scheduler use redis
Please have a look at this question I posted on[ StackOverflow](https://stackoverflow.com/questions/62030844/celery-worker-not-picking-task-when-run-inside-docker-containers/62033217#62033217) it explains why we are getting this issue.
prefix wasn't used when populating the redis DB from CELERYBEAT_SCHEDULE setting, so the feature didn't work. this patch (hopefully) fixes that.
pep8 schedules.py and task.py add switcher REDIS_SAVE_ENTRY_BACK(True by default), sync schedule to db when beat closed. Fixes the periodic task can not be performed as expected due to system time...
Where to add new tasks in redis is it a list by the name 'CELERYBEAT_SCHEDULE' ? I added tasks to a list by the name CELERYBEAT_SCHEDULE but i dont see...
``` $ celery -A apps.myproject beat -l info celery beat v3.1.17 (Cipater) is starting. Configuration -> . broker -> redis://localhost:6379/0 . loader -> celery.loaders.app.AppLoader . scheduler -> celery.beat.PersistentScheduler . db...
It would be convenient to have git tags in this repo for each pypi release. Makes it easier to go back in time :) Thanks !
.iteritems() is used when .items() should of been in https://github.com/kongluoxing/celerybeatredis/commit/048123354c9cbbe93995f371af3598f2bd7a8f33#diff-32a767aff0598f95893ce0d66a6a19c1R272
