Add celery beat worker

2019-09-10 10:23:36 -04:00
parent c00f13de2c
commit ac0c194490
3 changed files with 5 additions and 1 deletions
--- a/atst/queue.py
+++ b/atst/queue.py
@@ -5,6 +5,7 @@ celery = Celery(__name__)

 def update_celery(celery, app):
    celery.conf.update(app.config)
+    celery.conf.CELERYBEAT_SCHEDULE = {}

    class ContextTask(celery.Task):
        def __call__(self, *args, **kwargs):