Explorar o código

AbortableTask must use the request, and not depend on magic kwargs.

Closes #383
David Arthur %!s(int64=14) %!d(string=hai) anos
pai
achega
736361873e
Modificáronse 2 ficheiros con 3 adicións e 1 borrados
  1. 1 0
      AUTHORS
  2. 2 1
      celery/contrib/abortable.py

+ 1 - 0
AUTHORS

@@ -69,5 +69,6 @@ Ordered by date of first contribution:
   Marcin Kuźmiński <marcin@python-works.com>
   Marcin Kuźmiński <marcin@python-works.com>
   Adriano Petrich <petrich@gmail.com>
   Adriano Petrich <petrich@gmail.com>
   David Strauss <david@davidstrauss.net>
   David Strauss <david@davidstrauss.net>
+  David Arthur <mumrah@gmail.com>
   Miguel Hernandez Martos <enlavin@gmail.com>
   Miguel Hernandez Martos <enlavin@gmail.com>
   Jannis Leidel <jannis@leidel.info>
   Jannis Leidel <jannis@leidel.info>

+ 2 - 1
celery/contrib/abortable.py

@@ -155,7 +155,8 @@ class AbortableTask(Task):
         often (for performance).
         often (for performance).
 
 
         """
         """
-        result = self.AsyncResult(kwargs["task_id"])
+        task_id = kwargs.get('task_id', self.request.id)
+        result = self.AsyncResult(task_id)
         if not isinstance(result, AbortableAsyncResult):
         if not isinstance(result, AbortableAsyncResult):
             return False
             return False
         return result.is_aborted()
         return result.is_aborted()