views.py 文件源码

def requeue_all(request, queue_index):
    queue_index = int(queue_index)
    queue = get_queue_by_index(queue_index)
    jobs = queue.get_jobs()

    if request.method == 'POST':
        # Confirmation received
        for job in jobs:
            requeue_job(job.id, connection=queue.connection)

        messages.info(request, _('You have successfully requeued all %d jobs!') % len(jobs))
        return redirect('rq_jobs', queue_index)

    context_data = admin.site.each_context(request)
    context_data.update({
        'title': _("Requeue All"),
        'queue_index': queue_index,
        'queue': queue,
        'total_jobs':len(jobs),
    })
    return render(request, 'django_rq/requeue_all.html', context_data)