further testing job
This commit is contained in:
@@ -45,10 +45,12 @@ from rowsandall_app.settings import (
|
|||||||
tpapilocation = "https://api.trainingpeaks.com"
|
tpapilocation = "https://api.trainingpeaks.com"
|
||||||
|
|
||||||
from celery import Celery,app
|
from celery import Celery,app
|
||||||
|
from django_rq import job
|
||||||
import time
|
import time
|
||||||
from async_messages import message_user,messages
|
from async_messages import message_user,messages
|
||||||
|
|
||||||
@app.task
|
@app.task
|
||||||
|
@job
|
||||||
def addcomment(userid,id):
|
def addcomment(userid,id):
|
||||||
time.sleep(5)
|
time.sleep(5)
|
||||||
w = Workout.objects.get(id=id)
|
w = Workout.objects.get(id=id)
|
||||||
|
|||||||
@@ -2189,10 +2189,9 @@ from django.contrib import messages
|
|||||||
def workout_test_task_view(request,id=0):
|
def workout_test_task_view(request,id=0):
|
||||||
row = Workout.objects.get(id=id)
|
row = Workout.objects.get(id=id)
|
||||||
res = addcomment(request.user.id,row.id)
|
res = addcomment(request.user.id,row.id)
|
||||||
if settings.DEBUG:
|
|
||||||
res = addcomment.delay(request.user.id,row.id)
|
res = addcomment.delay(request.user.id,row.id)
|
||||||
else:
|
|
||||||
res = queuehigh.enqueue(addcomment,request.user.id,row.id)
|
|
||||||
|
|
||||||
messages.error(request,'Let op, Sander!')
|
messages.error(request,'Let op, Sander!')
|
||||||
url = reverse(workout_edit_view,
|
url = reverse(workout_edit_view,
|
||||||
|
|||||||
Reference in New Issue
Block a user