Получение отдельного идентификатора задачи в цепочке celery в Django

Я запускаю скрепер в фоновом режиме, используя цепочку celery. У меня есть 2 задачи, которые должны выполняться синхронно.

result = chain(taskOne.si(data= data), taskTwo(data = data)).delay()

Этот код работает, так как я могу видеть возвращаемые данные в терминале. Однако я не смог получить идентификатор задачи для каждой отдельной задачи.

Я пытался присвоить им переменную, но она не запускает цепочку celery.

result = chain(taskOneData = taskOne.si(data= data), taskTwoData = taskTwo(data = data)).delay()

если я выведу 'result', он покажет мне только идентификатор последней задачи.

Вернуться на верх