Как найти дату начала и дату окончания конкретной задачи в dag в потоке воздуха?

Question

Я использую kwargs ['execute_date'] для получения даты выполнения dag, но она дает время, когда вызывается общий dag, но мне нужно время, когда определенная задача запускается и заканчивается в потоке воздуха.

Answer 1

• Используйте get_task_instance() служебную функцию для получения TaskInstance
• Из TaskInstance объекта вы можете получить start_date & end_date

---

Как обозначение, context / kwargs содержат end_date & END_DATE (noda *) 1027 * -формат), но не start_date