Update alarm_kafka_connect_v2.py

dags/kafka/alarm_kafka_connect_v2.py

@@ -106,9 +106,7 @@ 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']
+    tasks_list = connector_status_dict['status']['tasks']
     error_tasks = 0
     for task in tasks_list:
         if task['state'] != 'RUNNING':