From 0fe86f1d66f4ef3f33e6145c763930bb828fec38 Mon Sep 17 00:00:00 2001 From: chmnata Date: Tue, 3 Dec 2024 15:47:20 +0000 Subject: [PATCH] #1086 Add message for no data alert --- dags/bluetooth_check_readers_temp.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dags/bluetooth_check_readers_temp.py b/dags/bluetooth_check_readers_temp.py index 6d9e52133..384ed25c9 100644 --- a/dags/bluetooth_check_readers_temp.py +++ b/dags/bluetooth_check_readers_temp.py @@ -60,7 +60,8 @@ def blip_pipeline(): pipeline_check = SQLCheckOperatorWithReturnValue( task_id = 'pipeline_check', conn_id = 'bt_bot', - sql = '''SELECT (COUNT(*) > 0) AS "_check" + sql = '''SELECT (COUNT(*) > 0) AS "_check", + 'There are no data inserted for '|| '{{ ds }}' AS msg FROM bluetooth.aggr_5min WHERE datetime_bin >='{{ ds }}' and datetime_bin < '{{ tomorrow_ds }}' LIMIT 1'''