Update clear_tasks_container_logs.py

dags/airflow/clear_tasks_container_logs.py

@@ -6,6 +6,9 @@ from airflow.operators.python_operator import PythonOperator
 from datetime import datetime, timedelta
 import os,logging
 
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
 default_args = {
     'owner': 'tangxianggang',
     'depends_on_past': False,
@@ -24,7 +27,7 @@ def clear_worker_logs():
     dt = datetime.now() - timedelta(minutes=1445)
     time_str = dt.strftime('%Y-%m-%d')
     cmd = 'rm -rf /opt/bitnami/airflow/logs/*/*/%s*' % (time_str)
-    logging.info('exec cmd : ' + cmd)
+    logger.info('exec cmd : ' + cmd)
     os.system(cmd)
 
 task = PythonOperator(