modify logging.debug -> logging.info

dags/flink/alarm_flink_job.py

@@ -83,8 +83,8 @@ def get_jobs(cmd):
         (stdout, stderr) = run_command(cmd, timeout)
         stdout = stdout.decode()
         stderr = stderr.decode()
-        logging.debug(stderr)
-        logging.debug(stdout)
+        logging.info(stderr)
+        logging.info(stdout)
 
         if 'Could not resolve host' in stderr and not stdout:
             msg = '\n- **error_msg**: Could not resolve host %s' % (cmd)

dags/kafka/alarm_kafka_connect.py

@@ -84,8 +84,8 @@ def get_kafka_connectors(cmd):
         (stdout, stderr) = run_command(cmd, timeout)
         stdout = stdout.decode()
         stderr = stderr.decode()
-        logging.debug(stderr)
-        logging.debug(stdout)
+        logging.info(stderr)
+        logging.info(stdout)
 
         if 'Could not resolve host' in stderr and not stdout:
             msg = '\n- **error_msg**: Could not resolve host %s' % (cmd)
@@ -114,8 +114,8 @@ def get_connector_status(cmd):
         (stdout, stderr) = run_command(cmd, timeout)
         stdout = stdout.decode()
         stderr = stderr.decode()
-        logging.debug(stderr)
-        logging.debug(stdout)
+        logging.info(stderr)
+        logging.info(stdout)
 
         outdict = json.loads(stdout)
     except TimeoutError:

dags/kafka/alarm_kafka_connect_v2.py

@@ -82,8 +82,8 @@ def get_kafka_connectors_status(cmd):
         (stdout, stderr) = run_command(cmd, timeout)
         stdout = stdout.decode()
         stderr = stderr.decode()
-        logging.debug(stderr)
-        logging.debug(stdout)
+        logging.info(stderr)
+        logging.info(stdout)
 
         if 'Could not resolve host' in stderr and not stdout:
             msg = '\n- **error_msg**: Could not resolve host %s' % (cmd)