от
Я запланировал запуск групп DAG с воздушным потоком, в каждом из них есть одна задача. Когда DAG запускаются, задачи внутри них не выполняются. Вот мой код для того же (я пытаюсь SSH на сервер EC2 и запускаю команду bash):
from datetime import timedelta, datetime
from airflow import DAG
from airflow.contrib.operators.ssh_operator import SSHOperator


default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'email': ['removed@example.com'],
    'email_on_failure': True,
    'email_on_retry': True,
    'start_date': datetime.now() 

Интерфейс Airflow показывает, что DAG находится в рабочем состоянии, но фактическая задача внутри DAG никогда не выполняется, я что-то упустил в своем коде?


Кроме того, есть ли способ принудительно запустить DAG независимо от расписания CRON?
    

        

Ваш ответ

Отображаемое имя (по желанию):
Конфиденциальность: Ваш электронный адрес будет использоваться только для отправки уведомлений.
Анти-спам проверка:
Чтобы избежать проверки в будущем, пожалуйста войдите или зарегистрируйтесь.

2 Ответы

0 голосов
от
Задача, застрявшая в «расписании», обычно означает, что у вас нет пула или очереди нет. Вы используете местного исполнителя? если да, работает ли планировщик? Вы можете принудительно запустить (или проверить) задачу с помощью командной строки.     
0 голосов
от
Нет ничего плохого в том, что вы, даг, проверьте свои настройки. Можете ли вы поделиться своим файлом cfg?     
...