Update DAG fsens

interTwin-eu · Apr 13, 2024 · e203458 · e203458
1 parent 73e2033
commit e203458
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/dags_airflow_ale_httpsensor.py b/dags_airflow_ale_httpsensor.py
@@ -47,9 +47,25 @@ def check_response_usr(response):
    js = response.json()
    output=js[0]
 
-   LoggingMixin().log.info("Member of the list is %s",type(output))
+   flag=None
+
+
+   if(js):
+    LoggingMixin().log.info("Read json object")
+
+
+    if((output['name']=="Leanne Graham")and(output['username']=="Bret")): 
+      flag=True
+    else:
+      flag=False   
+   else:
+    flag=False
+
+   return flag
+
+
 
-   return True 
+   return flag 
 
 checkNItems = HttpSensor(task_id="check", 
   http_conn_id="fakeAPIPlaceh",