Celery、Django.. 如何创建任务/线程启动子任务/线程?
我正在用 Django 搭配 Celery,想要创建一个任务,像下面这样:
class task1 (Task)
def run (self):
launch_some_other_task.delay()
但是好像不太管用。我可以详细讲讲我的代码,但我想先问问,这种做法到底行不行,因为我这边试了没成功。我觉得这样做很有必要,因为我在使用 Selenium,一个网页测试框架,有时候它会卡住,导致我无法得到任何输出。所以我想在某个条件不满足时能把它终止掉(比如在规定的时间内更新一个 memcache 变量到某个值)。
谢谢你们的建议!
1 个回答
0
确保你在你的 urls.py
文件中添加了以下内容:
import djcelery
djcelery.setup_loader()