1
我想使用芹菜的AbortableTask功能,但文档示例似乎并没有为我工作。给出的例子是:Django芹菜AbortableTask用法
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)
我在做什么错?
我给这个一杆(有意义),但错误依然存在。我绝对不能把任务称为正确的。 – Anon 2010-09-07 17:28:22
我给了这个又一次尝试,因为它看起来是对的,现在它可以工作。我假设我只是没有用任务更新文件。 – Anon 2010-09-08 17:50:19