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

fixes for 3.9

Browse Source
This commit is contained in:
Sander Roosendaal
2023-06-23 17:11:46 +02:00
parent 61b4607e5b
commit a070911c33
2 changed files with 19 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

Binary file not shown.

36
rowers/views/otherviews.py
View File

@@ -38,23 +38,24 @@ def failed_queue_view(request):
if not request.user.is_staff: # pragma: no cover if not request.user.is_staff: # pragma: no cover
raise PermissionDenied("Not Allowed") raise PermissionDenied("Not Allowed")
q = Queue(connection=Redis())
registry = q.failed_job_registry
resultslist = [] resultslist = []
for queuename in ['high','default','low']:
for id in registry.get_job_ids(): # pragma: no cover q = Queue(queuename,connection=Redis())
job = Job.fetch(id,connection=Redis()) registry = q.failed_job_registry
traceback = str(job.exc_info)
info = { for id in registry.get_job_ids(): # pragma: no cover
'id': job.id, job = Job.fetch(id,connection=Redis())
'started_at': job.started_at, traceback = str(job.exc_info)
'traceback1': traceback,
} info = {
'id': job.id,
'started_at': job.started_at,
'traceback1': traceback,
}
resultslist += [info]
resultslist += [info]
return render(request, return render(request,
"failed_jobs.html", "failed_jobs.html",
@@ -69,11 +70,12 @@ def failed_queue_empty(request):
if not request.user.is_staff: # pragma: no cover if not request.user.is_staff: # pragma: no cover
raise PermissionDenied("Not Allowed") raise PermissionDenied("Not Allowed")
q = Queue(connection=Redis()) for queuename in ['high','default','low']:
registry = q.failed_job_registry q = Queue(queuename,connection=Redis())
registry = q.failed_job_registry
for id in registry.get_job_ids(): for id in registry.get_job_ids():
registry.remove(id,delete_job=True) registry.remove(id,delete_job=True)
return HttpResponseRedirect(reverse('failed_queue_view')) return HttpResponseRedirect(reverse('failed_queue_view'))