Посмотреть результаты и логи задач Apache Airflow™
Инструкция описывает веб-интерфейс Apache Airflow™ 3.1.8. Перед началом запустите DAG.
Открыть результат запуска
- Откройте веб-интерфейс Apache Airflow™, перейдите в Dags и выберите DAG.
- На вкладке Runs выберите нужный запуск по времени и идентификатору.
- Проверьте состояние запуска и его задач. Для просмотра зависимостей используйте Graph, для сравнения задач в разных запусках — Grid.
Проверяйте состояния отдельных задач, даже если запуск завершился с success: итоговое состояние зависит от конечных задач и их правил запуска. Подробнее — в документации Apache Airflow™.
Прочитать логи задачи
- В выбранном запуске откройте нужную задачу и вкладку Logs.
- Если задача выполнялась повторно, выберите нужную попытку. У каждой попытки свой лог.
- Найдите сообщение об ошибке или ожидаемый результат. Для задачи
greetиз примера в логе должно бытьHello from Airflow!.
Возвращенное значение задачи доступно на вкладке XCom. Для greet это строка Hello from Airflow!.
Описание вкладок приведено в обзоре интерфейса Apache Airflow™, а выбор попыток — в описании истории задачи.
После устранения причины ошибки можно повторить задачу. Если она еще не начала выполняться, воспользуйтесь диагностикой ожидания.
Если лог недоступен
Проверьте выбранные запуск, задачу и попытку. У задачи, которая еще не начала выполняться, лог может отсутствовать.
Затем в консоли управления Stackland откройте карточку кластера Apache Airflow™ и проверьте раздел Логи задач на вкладке Основное:
- При локальном хранении логи могут быть утрачены после пересоздания или удаления пода. Для последующих запусков включите удаленное хранение.
- При удаленном хранении проверьте бакет, путь и права на запись и чтение логов. Сообщение об ошибке подключения в Logs поможет определить причину.
Изменение способа хранения не переносит уже записанные логи. Включайте удаленное хранение до запуска задач, логи которых нужно сохранить. Подробнее — в разделе Логи задач.