Как прервать задачу celery?

Question

[Станислав Сомов]

Простой пример

from celery import Celery

app = Celery('hello', broker='redis://localhost:6379/0')
id_task=''

@app.task(bind=True)
def testtask(self):
    id_task=str(self.request.id)
    while True:
        pass
    return 'ok'

def stoptask():
    ???? (task_id)

Пробовал так
from celery.contrib.abortable import AbortableAsyncResult

stop = AbortableAsyncResult(task_id)
stop.abort()

Ничего не происходит.

Comments

[Станислав Сомов]

Celery 3.1.23
Python 2.7.12

Answer 1

[Сергей Горностаев]

Во-первых, таск должен быть Abortable:

from celery.contrib.abortable import AbortableTask

@app.task(bind=True, base=AbortableTask)
def testtask(self):
    ...

Во-вторых, вместо while True: надо while not self.is_aborted():

Comments

[Станислав Сомов]

Работает, но это не совсем то чего ожидал.
получается что self.is_aborted() это обычный чек, тогда для чего эта куча кода.
Предполагал именно ресет задачи.
И какова реализация если код вида

def testtask(self):
    n1()
    n2()
    n3()
    n4()
....
    nn()

или ближе к рекомендациям

@app.task(bind=True, base=AbortableTask)
def testtask(self):
    test()

def test():
    while True:
        pass

[Сергей Горностаев]

DarkDemon, при организации параллельного выполнения задач, независимо от типа параллельности и языка реализации, хорошей практикой является, когда поток выполнения сам отвечает за свой жизненный цикл. В Java, например, даже убрали возможность принудительно остановить поток. Если в Celery надо остановить задачу жёстко, можно использовать функцию revoke:
app.control.revoke(task_id, terminate=True)
Но это может не остановить задачу находящуюся в ожидании заблокированного системного вызова. Или может привести к сбоям.