Я использую Apache Airflow, и я хотел, чтобы он отправлял мне электронное письмо, когда есть промах. Вот моя конфигурация Configuration
Я создал даг-ран, который точно не попадает в слот.
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.bash_operator import BashOperator
args = {
'owner': 'airflow'
, 'depends_on_past': False
, 'start_date': datetime(2018, 8, 17, 0, 0)
, 'retries': 0
, 'sla': timedelta(seconds=15)
, 'email': ['[email protected]']
, 'email_on_failure': True
, 'email_on_retry': True
}
dag = DAG('sla-email-test'
, default_args=args
, max_active_runs=1
, schedule_interval="@daily")
t1 = BashOperator(
task_id='timeout',
bash_command='sleep 60',
retries=0,
dag=dag,
)
К сожалению, он не отправил никаких электронных писем. Вывод
Что может быть причиной, могу ли я использовать графический интерфейс, чтобы просмотреть логи об этом?
