import airflow log

interTwin-eu · Apr 12, 2024 · 15ec33f · 15ec33f
1 parent 9267b1a
commit 15ec33f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dags_airflow_ale_httpsensor.py b/dags_airflow_ale_httpsensor.py
@@ -1,8 +1,10 @@
 import airflow.utils.dates
+from airflow.utils.log.logging_mixin import LoggingMixin
 from airflow import DAG
 from airflow.operators.dummy import DummyOperator
 from airflow.providers.http.sensors.http import HttpSensor
 
+
 dag = DAG(
     dag_id="httpsens_exmp",
     start_date=airflow.utils.dates.days_ago(3),
@@ -13,7 +15,7 @@
 
 def check_response_itm(response):
     js = response.json()
-    print("The json var is a ",type(js))
+    LoggingMixin().log.info("Json var type is",type(js))
 
     return True