fix:

EcoDataFlow · Jan 11, 2024 · 84dcb4a · 84dcb4a
1 parent 504d37a
commit 84dcb4a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dags/air/air_quality_dag.py b/dags/air/air_quality_dag.py
@@ -90,6 +90,8 @@ def fetch_data_and_save_csv(**context):
     }
     df_selected["metro"] = df_selected["metro"].map(new_metro_values)
 
+    for col_name in ["so2", "co", "o3", "no2", "pm10", "pm25"]:
+        df_selected.loc[df_selected[col_name] == "-", col_name] = ""
     # convert to csv
     df_selected.to_csv("dags/air/output.csv", index=False)