First schedule

app/celery/tasks.py

@@ -12,7 +12,14 @@ from sqlalchemy.exc import SQLAlchemyError
 from app.aws import s3
 from datetime import datetime
 from utils.template import Template
-from utils.recipients import RecipientCSV, first_column_heading
+from utils.recipients import RecipientCSV
+
+
+@notify_celery.task(name="log_this")
+def do_test():
+    current_app.logger.info(
+        "here"
+    )
 
 
 @notify_celery.task(name="process-job")
@@ -27,9 +34,9 @@ def process_job(job_id):
     )
 
     for recipient, personalisation in RecipientCSV(
-        s3.get_job_from_s3(job.bucket_name, job_id),
-        template_type=template.template_type,
-        placeholders=template.placeholders
+            s3.get_job_from_s3(job.bucket_name, job_id),
+            template_type=template.template_type,
+            placeholders=template.placeholders
     ).recipients_and_personalisation:
 
         encrypted = encryption.encrypt({

config.py

@@ -1,3 +1,4 @@
+from datetime import timedelta
 from kombu import Exchange, Queue
 import os
 
@@ -35,12 +36,13 @@ class Config(object):
     CELERY_TIMEZONE = 'Europe/London'
     CELERY_ACCEPT_CONTENT = ['json']
     CELERY_TASK_SERIALIZER = 'json'
-    # CELERYBEAT_SCHEDULE = {
-    #     'refresh-queues': {
-    #         'task': 'refresh-services',
-    #         'schedule': timedelta(seconds=5)
-    #     }
-    # }
+    CELERY_IMPORTS = ('app.celery.tasks',)
+    CELERYBEAT_SCHEDULE = {
+        'tasks': {
+            'task': 'log_this',
+            'schedule': timedelta(seconds=5)
+        }
+    }
     CELERY_QUEUES = [
         Queue('sms', Exchange('default'), routing_key='sms'),
         Queue('email', Exchange('default'), routing_key='email'),
@@ -52,7 +54,6 @@ class Config(object):
         Queue('bulk-email', Exchange('default'), routing_key='bulk-email'),
         Queue('email-invited-user', Exchange('default'), routing_key='email-invited-user')
     ]
-    CELERY_IMPORTS = ('app.celery.tasks',)
     TWILIO_ACCOUNT_SID = os.getenv('TWILIO_ACCOUNT_SID')
     TWILIO_AUTH_TOKEN = os.getenv('TWILIO_AUTH_TOKEN')
     TWILIO_NUMBER = os.getenv('TWILIO_NUMBER')

scripts/run_celery_beat.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+set -e
+
+source environment.sh
+celery -A run_celery.notify_celery beat --loglevel=INFO