Skip to content

A
airflow-dags-hub
Commit 3bc95c79 authored by 唐香港's avatar 唐香港
Browse files
Options

Update airflow_heartbeat_detection.py

parent f261a1da
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
dags/airflow/airflow_heartbeat_detection.py
View file @ 3bc95c79
...@@ -27,8 +27,8 @@ dag = DAG( ...@@ -27,8 +27,8 @@ dag = DAG(
def heartbeat_alarm(**kwargs): def heartbeat_alarm(**kwargs):
logging.info('start heartbeat alarm') logging.info('start heartbeat alarm')
title = 'airflow_heartbeat_detection' title = 'airflow_heartbeat_detection'
msg = '\n- I am airflow, I will notify you once every 100 minutes.\ msg = '\n- I am airflow, I will notify you once every 50 minutes.\
If I have not notified after 100 minutes, I have already hanged up.SOS...' If I have not notified after 50 minutes, I have already hanged up.SOS...'
message = '''I am airflow, I am still alive.!!! message = '''I am airflow, I am still alive.!!!
\n#### DAG_ID: %s \n#### DAG_ID: %s
\n#### TASKID: %s \n#### TASKID: %s
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment