celery: start periodic tasks

flowspy/celery.py

 from __future__ import absolute_import, unicode_literals
 import os
 from celery import Celery
+from flowspy import settings
 
 # set the default Django settings module for the 'celery' program.
 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'flowspy.settings')
@@ -16,6 +17,7 @@ app.config_from_object('django.conf:settings', namespace='CELERY')
 # Load task modules from all registered Django app configs.
 app.autodiscover_tasks()
 
+app.conf.beat_schedule = settings.CELERYBEAT_SCHEDULE
 
 @app.task(bind=True)
 def debug_task(self):

runfod.sh

@@ -30,7 +30,7 @@ echo "starting redis" 1>&2
 /usr/bin/redis-server &
 
 echo "Starting FoD celeryd in background" 1>&2
-celery worker -A flowspy --concurrency=2 --detach -l debug -f celery.log
+celery worker -A flowspy -B --concurrency=2 --detach -l debug -f celery.log
 
 echo "Starting FoD gunicorn in foreground" 1>&2
 #exec ./manage.py runserver 0.0.0.0:8000