sander/rowsandall
Private
Public Access
1
0
Fork 0
Code Activity

bla

Browse Source
This commit is contained in:
Sander Roosendaal
2019-05-25 20:29:03 +02:00
parent a2748720f6
commit 8788d3833a
2 changed files with 33 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
rowers/tests/testdata/testdata.csv.gz vendored
View File

Binary file not shown.

66
rowers/views/statements.py
View File

@@ -621,40 +621,40 @@ def raise_500(request):
else: else:
return HttpResponse("invalid") return HttpResponse("invalid")
@login_required() #@login_required()
def test_job_view(request,aantal=100): #def test_job_view(request,aantal=100):
#
# session_key = request.session._session_key
#
# job = myqueue(queuehigh,long_test_task,int(aantal),
# session_key=session_key)
#
#
# try:
# request.session['async_tasks'] += [(job.id,'long_test_task')]
# except KeyError:
# request.session['async_tasks'] = [(job.id,'long_test_task')]
#
# url = reverse(session_jobs_status)
#
# return HttpResponseRedirect(url)
session_key = request.session._session_key #@login_required()
#def test_job_view2(request,aantal=100):
job = myqueue(queuehigh,long_test_task,int(aantal), #
session_key=session_key) #
# job = myqueue(queuehigh,long_test_task2,int(aantal),
# secret=settings.PROGRESS_CACHE_SECRET)#
try: #
request.session['async_tasks'] += [(job.id,'long_test_task')] #
except KeyError: # try:
request.session['async_tasks'] = [(job.id,'long_test_task')] # request.session['async_tasks'] += [(job.id,'long_test_task2')]
# except KeyError:
url = reverse(session_jobs_status) # request.session['async_tasks'] = [(job.id,'long_test_task2')]
#
return HttpResponseRedirect(url) # url = reverse(session_jobs_status)
#
@login_required() # return HttpResponseRedirect(url)
def test_job_view2(request,aantal=100):
job = myqueue(queuehigh,long_test_task2,int(aantal),
secret=settings.PROGRESS_CACHE_SECRET)
try:
request.session['async_tasks'] += [(job.id,'long_test_task2')]
except KeyError:
request.session['async_tasks'] = [(job.id,'long_test_task2')]
url = reverse(session_jobs_status)
return HttpResponseRedirect(url)
@csrf_exempt @csrf_exempt
def post_progress(request,id=None,value=0): def post_progress(request,id=None,value=0):