小编Avi*_*mar的帖子

完成执行每个 dags 后，如何在气流中获得成功邮件。

这是我尝试过的。我正在尝试在完成 dags 后收到成功邮件 任何人都可以帮助我。我已经导入了所有需要的文件。

i = datetime.now()

default_args = {
'owner': 'owner',
'depeneds_on_past': False,
'start_date': datetime(i.year, i.month, i.day-1),
'email': ['owner@gmail.com'],
'email_on_failure': True,
'email_on_retry': True,
'email_on_success': True,
'retries': 0,
'retry_delay': timedelta(minutes=10)
}

dag = DAG('update', default_args = default_args, 
schedule_interval="0 3 * * *")


t0 = PythonOperator(
task_id='clear',
python_callable=empty_tables,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)

# Add tasks now 
t1 = BashOperator(
task_id='export',
bash_command=script,
dag=dag
)


t2 = PythonOperator(
task_id='load',
python_callable=load,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)



t0 >> t1 >> …