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

Merge branch 'release/v20.0.2'

Browse Source
This commit is contained in:
Sander Roosendaal
2023-06-23 17:23:14 +02:00
parent 209f02563a b4b84a4739
commit e0bdb1d2f2
1 changed files with 29 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
rowers/views/otherviews.py
View File

@@ -45,7 +45,19 @@ def failed_queue_view(request):
registry = q.failed_job_registry registry = q.failed_job_registry
for id in registry.get_job_ids(): # pragma: no cover for id in registry.get_job_ids(): # pragma: no cover
success = 0
try:
job = Job.fetch(id,connection=Redis()) job = Job.fetch(id,connection=Redis())
success = 1
except:
try:
id = id.replace('rq:job','')
job = Job.fetch(id,connection=Redis())
success = 1
except:
pass
if success:
traceback = str(job.exc_info) traceback = str(job.exc_info)
info = { info = {
@@ -75,7 +87,14 @@ def failed_queue_empty(request):
registry = q.failed_job_registry registry = q.failed_job_registry
for id in registry.get_job_ids(): for id in registry.get_job_ids():
try:
registry.remove(id,delete_job=True) registry.remove(id,delete_job=True)
except:
id = id.replace('rq.job','')
try:
registry.remove(id,delete_job=True)
except:
pass
return HttpResponseRedirect(reverse('failed_queue_view')) return HttpResponseRedirect(reverse('failed_queue_view'))