Update alarm_kafka_connect_v2.py

dags/kafka/alarm_kafka_connect_v2.py

@@ -14,7 +14,7 @@ import airflow
 #variable parameter
 DAG_ID = 'alarm_kafka_connect_v2'
 START_DATE = datetime.now() - timedelta(minutes=30)
-SCHEDULE_INTERVAL = timedelta(minutes=15)
+SCHEDULE_INTERVAL = timedelta(minutes=5)
 
 SERVICES = [
 'es-gmei-test-cp-kafka-connect',
@@ -106,6 +106,8 @@ def judge_connector_status(connector_status_dict, connector):
         msg = "\n- **connector_name**: %s, **is_running**: false" % (connector)
         logging.error(msg)
         return (False, msg)
+    print(connector_status_dict)
+    print(type(connector_status_dict))
     tasks_list = connector_status_dict['tasks']
     error_tasks = 0
     for task in tasks_list: