Update airflow_heartbeat_detection.py

dags/airflow/airflow_heartbeat_detection.py

@@ -21,14 +21,14 @@ default_args = {
 dag = DAG(
     dag_id='airflow_heartbeat_detection',
     default_args=default_args,
-    schedule_interval=timedelta(minutes=60)
+    schedule_interval=timedelta(minutes=30)
 )
 
 def heartbeat_alarm(**kwargs):
     logging.info('start heartbeat alarm')
     title = 'airflow_heartbeat_detection'
     msg = '\n- I am airflow, I will notify you once every two hours.\
-    If I have not notified after one hours, I have already hanged up.SOS...'
+    If I have not notified after 30 minutes, I have already hanged up.SOS...'
     message = '''I am airflow, I am still alive.!!!
     \n#### DAG_ID:  %s 
     \n#### TASKID:  %s