From ac0c19449015c9371fd2e176e6aafa5e56695aeb Mon Sep 17 00:00:00 2001
From: richard-dds <richard-ctr@friends.dds.mil>
Date: Tue, 10 Sep 2019 10:23:36 -0400
Subject: [PATCH] Add celery beat worker

---
 .gitignore       | 3 +++
 atst/queue.py    | 1 +
 script/dev_queue | 2 +-
 3 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/.gitignore b/.gitignore
index cf9591a0..36a8261e 100644
--- a/.gitignore
+++ b/.gitignore
@@ -62,3 +62,6 @@ browserstacklocal
 # configuration files
 override.ini
 atst-overrides.ini
+
+# binary file created by celery beat
+celerybeat-schedule
diff --git a/atst/queue.py b/atst/queue.py
index e3ae049d..d71532b1 100644
--- 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):
diff --git a/script/dev_queue b/script/dev_queue
index 670dd96b..4e8720ee 100755
--- a/script/dev_queue
+++ b/script/dev_queue
@@ -4,7 +4,7 @@
 
 set -e
 
-WORKER="pipenv run celery -A celery_worker.celery worker --loglevel=info"
+WORKER="pipenv run celery -A celery_worker.celery worker --loglevel=info -B"
 
 if [[ `command -v entr` ]]; then
   find atst | entr -r $WORKER