Я использую среду сельдерея для выполнения асинхронных c задач, где я определял задачи, используя следующий код:
class CallbackTask(Task):
def on_success(self, retval, task_id, args, kwargs):
root_id = self.request.root_id
task_name = self.request.task
# blah
return super(CallbackTask, self).on_success(retval, task_id, args, kwargs)
def on_failure(self, exc, task_id, args, kwargs, info):
root_id = self.request.root_id
task_name = self.request.task
# blah
return super(CallbackTask, self).on_failure(exc, task_id, args, kwargs, info)
@app.task(base=CallbackTask)
def mytask(photo_level, photo_sn):
# Do something
В настоящее время у меня возникают проблемы при отладке в @app.task(base=CallbackTask)
и self.request.task
, я нужно знать, как они установлены.
Может ли кто-нибудь помочь?