views.py 文件源码

def delete_job(request, queue_index, job_id):
    queue_index = int(queue_index)
    queue = get_queue_by_index(queue_index)
    job = Job.fetch(job_id, connection=queue.connection)

    if request.method == 'POST':
        # Remove job id from queue and delete the actual job
        queue.connection._lrem(queue.key, 0, job.id)
        job.delete()
        messages.info(request, _('You have successfully deleted %s') % job.id)
        return redirect('rq_jobs', queue_index)

    context_data = admin.site.each_context(request)
    context_data.update({
        'title': _("Delete Job"),
        'queue_index': queue_index,
        'job': job,
        'queue': queue,
    })
    return render(request, 'django_rq/delete_job.html', context_data)