我需要从models.py调用一个celery任务(在tasks.py中),唯一的问题是,tasks.py导入models.py,所以我无法从models.py导入tasks.py。
有没有什么方法可以仅使用名称来调用 celery 任务,而无需导入它?出于同样的原因(防止循环导入),ForeignKey 字段也实现了类似的操作。
就在这里。
您可以使用:
from celery.execute import send_task
send_task('my_task', [], kwargs)
确保您的任务函数有一个名称:
from celery import task
@task(name='my_task')
def my_task():
...
希望能帮助到你!
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)