Merge pull request #184 from FEWS-NET/HEA-780/MW12_TypeError_unsupported-operand-type_for_float_and_str

rhunwicks · web-flow · commit 58368ee199f6 · 2025-10-17T14:01:42.000-04:00
Add coverstion to numeric value before the aggregates
diff --git a/pipelines/assets/livelihood_activity.py b/pipelines/assets/livelihood_activity.py
@@ -1337,6 +1337,8 @@ def get_annotated_instances_from_dataframe(
         # Annotate the output metadata with completeness information
         # Get the summary dataframe, grouped by strategy_type
         summary_df = pd.DataFrame(reported_summary_output.value["LivelihoodActivity"])
+        for col in ["income", "expenditure", "kcals_consumed"]:
+            summary_df[col] = pd.to_numeric(summary_df[col], errors="coerce").fillna(0)
         summary_df = (
             summary_df[["strategy_type", "income", "expenditure", "kcals_consumed"]].groupby("strategy_type").sum()
         )

Original file line number	Diff line number	Diff line change
`@@ -1337,6 +1337,8 @@ def get_annotated_instances_from_dataframe(`
`1337`	`1337`	`# Annotate the output metadata with completeness information`
`1338`	`1338`	`# Get the summary dataframe, grouped by strategy_type`
`1339`	`1339`	`summary_df = pd.DataFrame(reported_summary_output.value["LivelihoodActivity"])`
	`1340`	`+ for col in ["income", "expenditure", "kcals_consumed"]:`
	`1341`	`+ summary_df[col] = pd.to_numeric(summary_df[col], errors="coerce").fillna(0)`
`1340`	`1342`	`summary_df = (`
`1341`	`1343`	`summary_df[["strategy_type", "income", "expenditure", "kcals_consumed"]].groupby("strategy_type").sum()`
`1342`	`1344`	`)`