diff --git a/rowers/tests/testdata/testdata.tcx.gz b/rowers/tests/testdata/testdata.tcx.gz index eaaf5563..15254789 100644 Binary files a/rowers/tests/testdata/testdata.tcx.gz and b/rowers/tests/testdata/testdata.tcx.gz differ diff --git a/rowers/views/otherviews.py b/rowers/views/otherviews.py index b783496d..1536260a 100644 --- a/rowers/views/otherviews.py +++ b/rowers/views/otherviews.py @@ -38,23 +38,24 @@ def failed_queue_view(request): if not request.user.is_staff: # pragma: no cover raise PermissionDenied("Not Allowed") - q = Queue(connection=Redis()) - registry = q.failed_job_registry - - resultslist = [] + for queuename in ['high','default','low']: - for id in registry.get_job_ids(): # pragma: no cover - job = Job.fetch(id,connection=Redis()) - traceback = str(job.exc_info) + q = Queue(queuename,connection=Redis()) + registry = q.failed_job_registry - info = { - 'id': job.id, - 'started_at': job.started_at, - 'traceback1': traceback, - } + for id in registry.get_job_ids(): # pragma: no cover + job = Job.fetch(id,connection=Redis()) + traceback = str(job.exc_info) + + info = { + 'id': job.id, + 'started_at': job.started_at, + 'traceback1': traceback, + } + + resultslist += [info] - resultslist += [info] return render(request, "failed_jobs.html", @@ -69,11 +70,12 @@ def failed_queue_empty(request): if not request.user.is_staff: # pragma: no cover raise PermissionDenied("Not Allowed") - q = Queue(connection=Redis()) - registry = q.failed_job_registry + for queuename in ['high','default','low']: + q = Queue(queuename,connection=Redis()) + registry = q.failed_job_registry - for id in registry.get_job_ids(): - registry.remove(id,delete_job=True) + for id in registry.get_job_ids(): + registry.remove(id,delete_job=True) return HttpResponseRedirect(reverse('failed_queue_view'))