Update alarm_kafka_connect_v2.py

dags/kafka/alarm_kafka_connect_v2.py

@@ -82,12 +82,14 @@ def get_kafka_connectors_status(cmd):
         result = run_command(cmd, timeout)
         result = result.decode()
         logging.info(result)
-        if '--:--:--' in result:
-            raise TimeoutError(cmd, timeout)
         if 'Could not resolve host' in result:
             msg = '\n- **error_msg**: Could not resolve host %s' % (cmd)
             raise Exception(msg)
-        connectors_dict = json.loads(result.split('\n')[-1])
+        resMsg = result.split('\n')[-1]
+        logging.info("result of last line to resMag : " + resMsg)
+        if '--:--:--' in resMsg:
+            raise TimeoutError(cmd, timeout)
+        connectors_dict = json.loads(resMsg)
         if 'error_code' in connectors_dict:
             msg = '\n- **error_code**: ' + connectors_dict['error_code'] + '**error_msg**: ' + connectors_dict['message']
             logging.error(msg)