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

redis rq delete job and failed queue update

Browse Source
This commit is contained in:
Sander Roosendaal
2022-05-22 11:50:19 +02:00
parent 38b959ebd1
commit adf1002809
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
rowers/views/otherviews.py
View File

@@ -38,11 +38,14 @@ 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('failed', connection=Redis()) q = Queue(connection=Redis())
registry = q.failed_job_registry
resultslist = [] resultslist = []
for job in q.jobs: # pragma: no cover for id in registry.get_job_ids(): # pragma: no cover
job = Job.fetch(id,connection=Redis())
traceback = str(job.exc_info) traceback = str(job.exc_info)
info = { info = {
@@ -66,9 +69,11 @@ 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('failed', connection=Redis()) q = Queue(connection=Redis())
registry = q.failed_job_registry
q.empty() for id in registry.get_job_ids():
registry.remove(id,delete_job=True)
return HttpResponseRedirect(reverse('failed_queue_view')) return HttpResponseRedirect(reverse('failed_queue_view'))