Update alarm_kafka_connect_v2.py

dags/kafka/alarm_kafka_connect_v2.py

@@ -12,7 +12,7 @@ import os, json, logging, time, signal, platform, subprocess
 import airflow
 
 #variable parameter
-DAG_ID = 'alarm_kafka_connect'
+DAG_ID = 'alarm_kafka_connect_v2'
 START_DATE = datetime.now() - timedelta(minutes=30)
 SCHEDULE_INTERVAL = timedelta(minutes=15)