@@ -153,7 +153,7 @@ def _fetch_partition_rows_from_secondary_source(partition_dt: str) -> list[dict[
continue
demand_name = _secondary_demand_display_name(
- record.get("merge_leve2"),
+ record["merge_leve2"],
demand_raw,
)
if not demand_name:
xueyiming