fix
This commit is contained in:
@@ -45,7 +45,19 @@ def failed_queue_view(request):
|
||||
registry = q.failed_job_registry
|
||||
|
||||
for id in registry.get_job_ids(): # pragma: no cover
|
||||
success = 0
|
||||
try:
|
||||
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)
|
||||
|
||||
info = {
|
||||
@@ -75,7 +87,14 @@ def failed_queue_empty(request):
|
||||
registry = q.failed_job_registry
|
||||
|
||||
for id in registry.get_job_ids():
|
||||
try:
|
||||
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'))
|
||||
|
||||
|
||||
Reference in New Issue
Block a user