mirror of
https://github.com/django-q2/django-q2.git
synced 2026-09-15 21:47:53 +08:00
32 lines
753 B
Python
32 lines
753 B
Python
import time
|
|
|
|
from django.http import HttpResponse
|
|
from django.urls import reverse
|
|
|
|
from django_q import tasks
|
|
|
|
|
|
# internal function to be called with django_q
|
|
def new_task(run_for_minutes):
|
|
print("Task started")
|
|
time.sleep(run_for_minutes)
|
|
print("Task done")
|
|
return True
|
|
|
|
|
|
def add_task(request):
|
|
task_id = tasks.async_task(new_task, 5)
|
|
result_url = reverse("get_result", args=[task_id])
|
|
return HttpResponse(
|
|
f"Added async task with <a href='{result_url}'>Go to results</a>"
|
|
)
|
|
|
|
|
|
def get_result(request, task_id):
|
|
task = tasks.fetch(task_id)
|
|
if not task:
|
|
msg = "Task running... please refresh after some time"
|
|
else:
|
|
msg = f"Async task result: {task.result}"
|
|
return HttpResponse(msg)
|