Anular una tarea en ejecución en Apio dentro de django

Question

Me gustaría poder cancelar una tarea que se ejecuta desde una cola de Celery (usando rabbitMQ). Llamo a la tarea usando

task_id = AsyncBoot.apply_async(args=[name], name=name, connect_timeout=3) 

donde AsyncBoot es una tarea definida.

Puedo obtener la identificación de la tarea (suponiendo que sea la cadena larga que devuelve apply_async) y almacenarla en una base de datos, pero no estoy seguro de cómo llamar a un método de cancelación. Veo cómo hacer que los métodos abortable con la clase de tareas Abortables pero si sólo tengo la cadena id-tarea, Como llamar en .abort() en la tarea? Gracias.

Answer 1

apply_async devuelve una instancia AsyncResult, o en este caso un AbortableAsyncResult. Guarde el task_id y úselo para instanciar un nuevo AbortableAsyncResult más adelante, asegurándose de proporcionar el argumento opcional de back-end si no está usando el default_backend.

abortable_async_result = AsyncBoot.apply_async(args=[name], name=name, connect_timeout=3) 
myTaskId = abortable_async_result.task_id 

después:

abortable_async_result = AbortableAsyncResult(myTaskId) 
abortable_async_result.abort() 

Answer 2

¿Has visto la documentación de referencia? http://celeryq.org/docs/reference/celery.contrib.abortable.html

para abortar el uso tarea result.abort():

>>> result = AsyncBoot.apply_async(...) 
>>> result.abort()