Как я могу получить значение task_id для задачи из задачи? Здесь мой код:
from celery.decorators import task
from django.core.cache import cache
@task
def do_job(path):
"Performs an operation on a file"
# ... Code to perform the operation ...
cache.set(current_task_id, operation_results)
Идея заключается в том, что когда я создаю новый экземпляр задачи, я извлекаю task_id
из объекта задачи. Затем я использую идентификатор задачи, чтобы определить, завершилась ли задание. Я не хочу отслеживать задачу значением path
, потому что файл "очищается" после завершения задачи и может существовать или не существовать.
В приведенном выше примере, как бы получить значение current_task_id
?