views.py 文件源码

def import_corpus_view(request):
    if request.method == 'POST':
        corpus_id = request.POST.get('corpus_id', None)
        success = False
        corpus = Corpus.objects.get(pk=corpus_id)

        if corpus.status == 'NI':
            t = import_corpus_task.delay(corpus.pk)
            corpus.status = 'IR'
            corpus.current_task_id = t.task_id
            corpus.save()
            success = True
        if success:
            messages.success(request, "The {} corpus import was started successfully!".format(corpus.name))
        else:
            messages.error(request, "Something went wrong!")
    return redirect('pgdb:corpus_status')