Что такое chord в Celery?

Senior
135 просмотров
AFK Offer AI

Chord — группа задач + callback после завершения всех. from celery import chord; chord(group_of_tasks, callback.s()). Пример: chord([fetch.s(url) for url in urls], aggregate.s()) — скачать все URL параллельно, потом агрегировать результаты. Callback получает список результатов группы. Chord требует result backend (Redis, DB). Если одна задача в группе падает — chord error handler вызывается. chord_unlock — внутренняя задача, которая polling проверяет готовность группы. Полезен для map-reduce паттерна.

Следующий вопрос

Что такое __code__ объект?