Add scheduler Django app with heartbeat task

.gitignore

@@ -1,8 +1,13 @@
+# Python compiled files
+*.pyc
+__pycache__/
+
 # IDE specific directories
 .idea/
 
 # Ignoring Heroku files in their target versions
 .env
 
 # Project specific files that should not be exposed
-db.sqlite3
+db.sqlite3
+celerybeat-schedule

Procfile

@@ -1,2 +1,2 @@
 web: gunicorn application.wsgi
-worker: celery worker --app=application.celery
+worker: celery worker -B -l info -A application.celery

application/__init__.py

@@ -0,0 +1,5 @@
+# This will make sure the app is always imported when
+# Django starts so that shared_task will use this app.
+from .celery import app as celery_app
+
+__all__ = ("celery_app", )

application/settings.py

@@ -41,6 +41,7 @@
     "django.contrib.sessions",
     "django.contrib.messages",
     "django.contrib.staticfiles",
+    "scheduler.apps.SchedulerConfig",
 ]
 
 MIDDLEWARE = [
@@ -176,11 +177,13 @@
 
 CELERY_BEAT_SCHEDULE = {
     #
-    # A list of scheduled tasks
-    #
-    # "your-complex-task-name": {
-    #     "task": "task_function_name",
-    #     "schedule": 60.0,
-    # }
+    # A list of scheduled tasks which are supposed to be launched in selected
+    # intervals. By default, a simple heartbeat task is implemented so the
+    # logs should show the Celery worker is running fine.
     #
+    "celery_heartbeat": {
+        "task": "celery_heartbeat",
+        "schedule": 60.0,
+    }
+
 }

docker/.gitignore

@@ -1,3 +1,3 @@
 # This directory contains all the Docker volumes data and is not required
 # to be included in the respository.
-.data/*
+.data/

manage.py

@@ -1,11 +1,11 @@
 #!/usr/bin/env python
-"""Django's command-line utility for administrative tasks."""
+"""Django"s command-line utility for administrative tasks."""
 import os
 import sys
 
 
 def main():
-    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'application.settings')
+    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "application.settings")
     try:
         from django.core.management import execute_from_command_line
     except ImportError as exc:
@@ -17,5 +17,5 @@ def main():
     execute_from_command_line(sys.argv)
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     main()

scheduler/admin.py

@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.

scheduler/apps.py

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class SchedulerConfig(AppConfig):
+    name = "scheduler"

scheduler/models.py

@@ -0,0 +1,3 @@
+from django.db import models
+
+# Create your models here.

scheduler/tasks.py

@@ -0,0 +1,8 @@
+from datetime import datetime
+
+from celery import shared_task
+
+
+@shared_task(name="celery_heartbeat")
+def celery_heartbeat():
+    return "Celery heartbeat at {}".format(datetime.now())

scheduler/tests.py

@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.

scheduler/views.py

@@ -0,0 +1,3 @@
+from django.shortcuts import render
+
+# Create your views here.