Do not write empty csv instanceid file when sql query returns zero rows

sul-dlss · May 10, 2024 · 813cd58 · 813cd58
1 parent cbbd96b
commit 813cd58
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/libsys_airflow/plugins/data_exports/instance_ids.py b/libsys_airflow/plugins/data_exports/instance_ids.py
@@ -66,9 +66,12 @@ def save_ids(**kwargs) -> str:
     filestamp = kwargs.get("timestamp", datetime.now().strftime('%Y%m%d%H%M'))
     airflow = kwargs.get("airflow", "/opt/airflow")
     vendor = kwargs.get("vendor")
-    data = kwargs.get("data", "")
+    data = kwargs.get("data")
     kind = kwargs.get("kind")
 
+    if not data:
+        return
+
     data_path = (
         Path(airflow) / f"data-export-files/{vendor}/instanceids/{kind}/{filestamp}.csv"
     )