当使用celery更新Django模型字段时，避免递归save（）
||
我正在重写模型的save（）方法，以使用Celery调用异步任务。该任务还保存了模型，因此我遇到了递归的情况，即反复调用Celery任务。这是代码：
模型的保存方法：
def save(self, *args, **kwargs):
super(Route, self).save(*args, **kwargs)
from .tasks import get_elevation_data
get_elevation_data.delay(self)
from celery.decorators import task
@task()
def get_elevation_data(route):
...
route.elevation_data = results
route.save()
没有找到相关结果
已邀请:
1 个回复
翁茄口霉氖
def save(self, elevation_data=True, *args, **kwargs): super(Route, self).save(*args, **kwargs) if elevation_data: from .tasks import get_elevation_data get_elevation_data.delay(self)from celery.decorators import task @task() def get_elevation_data(route): ... route.elevation_data = results route.save(elevation_data=False)