Private
Public Access
1
0

changes to fix failed jobs

This commit is contained in:
2023-09-01 12:51:56 +02:00
parent 5b002a5159
commit d56c46967b
3 changed files with 12 additions and 6 deletions

View File

@@ -104,10 +104,16 @@ def failed_job_view(request, id=0): # pragma: no cover
if not request.user.is_staff:
raise PermissionDenied("Not Allowed")
q = Queue('failed', connection=Redis())
thejob = q.fetch_job(id)
thejob.delete()
for queuename in ['high','default','low']:
q = Queue(queuename, connection=Redis())
reqistry = q.failed_job_registry
for tid in registry.get_job_ids():
if tid == id:
try:
job = Job.fetch(id, connection=Redis())
registry.remove(id, delete_job=True)
except:
pass
return HttpResponseRedirect(reverse('failed_queue_view'))