Skip to content
Snippets Groups Projects

Celery and Redis

Merged Kenzo-Hugo Hillion requested to merge 34-celery-redis into dev
Files
17
import logging
from celery.decorators import task
from rest_framework.decorators import api_view
from rest_framework.response import Response
from metagenedb.celery_app import debug_task
logger = logging.getLogger(__name__)
@api_view()
def celery_test_view(request):
debug_task.delay()
return Response({"message": "Your task is being processed!"})
@task(name="test_celery_task")
def test_task(msg):
logger.info("Test Celery Task")
return msg
@task(name="poete")
def mul(x, y):
return x * y
@api_view()
def test_task_view(request):
msg = test_task.delay("poooouet")
muli = mul.delay(2, 4)
return Response({"message": f"Tested celery task: {msg.get(timeout=1)} {muli.get(timeout=1)}"})
Loading