mismatched colName

DEQbayres · DEQbayres · commit 1d0ceff66628 · 2025-12-22T14:35:17.000-08:00
dimPollutant.csv referred to column name analyte_name_deq while python referred to analyte_name
diff --git a/pipelines/aqs/run_pm25_only.py b/pipelines/aqs/run_pm25_only.py
@@ -34,7 +34,7 @@ def main(workers: int = 4) -> None:
 
     pm25 = df[df["group_store"].str.lower() == "pm25"]
     params = list(
-        pm25[["aqs_parameter", "analyte_name"]]
+        pm25[["aqs_parameter", "analyte_name_deq"]]
         .dropna()
         .itertuples(index=False, name=None)
     )

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ def main(workers: int = 4) -> None:`
`34`	`34`
`35`	`35`	`pm25 = df[df["group_store"].str.lower() == "pm25"]`
`36`	`36`	`params = list(`
`37`		`- pm25[["aqs_parameter", "analyte_name"]]`
	`37`	`+ pm25[["aqs_parameter", "analyte_name_deq"]]`
`38`	`38`	`.dropna()`
`39`	`39`	`.itertuples(index=False, name=None)`
`40`	`40`	`)`