Private
Public Access
1
0

try with standalone

This commit is contained in:
Sander Roosendaal
2017-05-10 14:51:06 +02:00
parent be2f6803d3
commit 50eda6b135
3 changed files with 33 additions and 3 deletions

View File

@@ -10,6 +10,7 @@ import rowingdata
from rowingdata import main as rmain from rowingdata import main as rmain
from rowingdata import rowingdata as rdata from rowingdata import rowingdata as rdata
import rowingdata import rowingdata
from async_messages import message_user,messages
from matplotlib.backends.backend_agg import FigureCanvas from matplotlib.backends.backend_agg import FigureCanvas
#from matplotlib.backends.backend_cairo import FigureCanvasCairo as FigureCanvas #from matplotlib.backends.backend_cairo import FigureCanvasCairo as FigureCanvas
@@ -17,6 +18,8 @@ import matplotlib.pyplot as plt
from matplotlib import figure from matplotlib import figure
import stravalib import stravalib
from django_rq import job
from utils import serialize_list,deserialize_list from utils import serialize_list,deserialize_list
@@ -25,6 +28,10 @@ from rowers.dataprepnodjango import new_workout_from_file
from django.core.mail import send_mail, BadHeaderError,EmailMessage from django.core.mail import send_mail, BadHeaderError,EmailMessage
# testing task # testing task
@app.task @app.task
def add(x, y): def add(x, y):

View File

@@ -0,0 +1,23 @@
if __name__ == '__main__':
import django
from django.conf import settings
django.setup()
import time
from celery import app
from django_rq import job
from async_messages import message_user,messages
from rowers.models import Workout
from django.contrib.auth.models import User
@app.task
@job
def addcomment2(userid,id):
print 'aap'
time.sleep(5)
w = Workout.objects.get(id=id)
w.notes += '\n the task has run'
w.save()
u = User.objects.get(id=userid)
messages.info(u,' The task has run')
return 1

View File

@@ -2182,15 +2182,15 @@ def workout_forcecurve_view(request,id=0,workstrokesonly=False):
'teams':get_my_teams(request.user), 'teams':get_my_teams(request.user),
}) })
from rowers.tpstuff import addcomment from rowers.tasks_standalone import addcomment2
from django.contrib import messages from django.contrib import messages
# Test asynchronous tasking and messaging # Test asynchronous tasking and messaging
@login_required() @login_required()
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 = addcomment2(request.user.id,row.id)
res = addcomment.delay(request.user.id,row.id) res = addcomment2.delay(request.user.id,row.id)
messages.error(request,'Let op, Sander!') messages.error(request,'Let op, Sander!')