test celery

Dockerfile

@@ -14,7 +14,7 @@ ENV PYTHONUNBUFFERED 1
 #    python3 python3-dev gcc \
 #    gfortran musl-dev \
 #    libffi-dev openssl-dev
-RUN apt-get update && apt-get -y install postgresql postgresql-contrib git libcairo2-dev pkg-config gcc
+RUN apt-get update && apt-get -y install postgresql postgresql-contrib git libcairo2-dev pkg-config gcc redis-tools
 
 
 # install dependencies

atlas/tasks.py

@@ -0,0 +1,13 @@
+from time import sleep
+from django.core.mail import send_mail
+from celery import shared_task
+
+@shared_task()
+def long():
+    """Sends an email when the feedback form has been submitted."""
+    for i in range(20):
+        sleep(1)  # Simulate expensive operation(s) that freeze Django
+        print(i)
+
+
+    return 10

atlas/views.py

@@ -117,6 +117,8 @@ from .filters import (
     SubspecialtyFilter,
 )
 
+from .tasks import long
+
 from django_tables2 import SingleTableView, SingleTableMixin
 from django_filters.views import FilterView
 
@@ -2982,6 +2984,10 @@ def collection_reset_answers(request, exam_id: int):
         raise Http404("Invalid request")
 
 def push_case_to_cimar(request, case_id):
+
+    long.delay()
+
+    return HttpResponse("Success")
     case = get_object_or_404(Case, pk=case_id)
 
     api = CimarAPI()

docker/docker-compose.yml

@@ -1,4 +1,11 @@
 services:
+  redis:
+    image: redis:7.4.2-alpine
+    expose:
+      - 6379
+    volumes:
+      - ./redis/redis.conf:/usr/local/etc/redis/redis.conf
+    command: ["redis-server", "/usr/local/etc/redis/redis.conf"]
   web:
     build: ./rad
     command: python manage.py runserver 0.0.0.0:8000

rad/__init__.py

@@ -0,0 +1,3 @@
+from .celery import app as celery_app
+
+__all__ = ("celery_app",)

rad/celery.py

@@ -0,0 +1,7 @@
+import os
+from celery import Celery
+
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "rad.settings")
+app = Celery("rad")
+app.config_from_object("django.conf:settings", namespace="CELERY")
+app.autodiscover_tasks()

rad/settings.py

@@ -318,9 +318,15 @@ STATICFILES_DIRS = (
 CIMAR_USERNAME = ""
 CIMAR_PASSWORD = ""
 
+# Celery settings
+CELERY_BROKER_URL = "redis://redis:6379"
+CELERY_RESULT_BACKEND = "redis://redis:6379"
+
 try:
     from .settings_local import *
 except ImportError as e:
     print(e)
     print("UNABLE TO IMPORT LOCAL SETTINGS")
     pass
+
+

requirements.txt

@@ -56,5 +56,5 @@ django-template-partials
 easy_thumbnails
 requests
 pygments
-celery
+celery[redis]
 redis