Использование Django Celery AbortableTask - PullRequest
Новая
       31

Использование Django Celery AbortableTask

1 голос
/ 07 сентября 2010

Я пытаюсь использовать функцию AbortableTask в Celery, но пример документации, похоже, не работает для меня.В приведенном примере: 

from celery.contrib.abortable import AbortableTask

def MyLongRunningTask(AbortableTask):

    def run(self, **kwargs):
        logger = self.get_logger(**kwargs)
        results = []
        for x in xrange(100):
            # Check after every 5 loops..
            if x % 5 == 0:  # alternatively, check when some timer is due
                if self.is_aborted(**kwargs):
                    # Respect the aborted status and terminate
                    # gracefully
                    logger.warning("Task aborted.")
                    return None
            y = do_something_expensive(x)
            results.append(y)
        logger.info("Task finished.")
        return results

и 

from myproject.tasks import MyLongRunningTask

def myview(request):

    async_result = MyLongRunningTask.delay()
    # async_result is of type AbortableAsyncResult

    # After 10 seconds, abort the task
    time.sleep(10)
    async_result.abort()

    ...

Однако я получаю сообщение об ошибке: 

TypeError: MyLongRunningTask() takes exactly 1 argument (0 given)

Что я делаю неправильно?

1 Ответ

2 голосов
/ 07 сентября 2010

Просто предположение, но я думаю, что это должно быть 

class MyLongRunningTask(AbortableTask)

, а не 

def MyLongRunningTask(AbortableTask)
...