Сбой задачи воздушного потока без пустого журнала и не отправляет электронную почту - PullRequest
Новая
       18

Сбой задачи воздушного потока без пустого журнала и не отправляет электронную почту

0 голосов
/ 05 ноября 2018

У меня есть группа доступности базы данных с 60 задачами (PythonsOperators), и в некоторых выполнениях различные задачи помечаются как невыполненные, но я не знаю причину, когда я перехожу в «Просмотр журнала», журнал пуст и когда я перехожу красный квадрат с надписью «Оператор»: ноль, что это значит?

Кажется, что он не выполнил задачу, но я не понимаю, почему.

Вопросы:

Почему Airflow помечает его как сбойный, но в журнале не отображается выполнение? Почему он не отправляет сообщение об ошибке, если задачи помечены как невыполненные?

Вот код Python, связанный с меткой: 

DEFAULT_ARGS = {
'owner': 'blablabla',
'depends_on_past': False,
'start_date': datetime(2018, 5, 8),
'catchup': False,
'email': ['mail@mail.com'],
'email_on_failure': True,
'email_on_retry': False,
'retries': 3,
'max_active_runs': 1,
'retry_delay': timedelta(minutes=5)
}

dag = DAG('dag_name',
default_args=DEFAULT_ARGS,
schedule_interval='20 0 * * *')

mylist = get_codes_list()

for item in mylist:
healthcheckerName = 'healthchecker_' + item

healthchecker = PythonOperator(
dag=dag,
task_id=healthcheckerName,
python_callable=prime_ops.check_last_budget_calculation(item),
queue=SPECIFIC_QUEUE,
pool=DEFAULT_PPC_POOL
)
...