fix double counting of observed boardings by time of day

BayAreaMetro · Mar 13, 2024 · 2e00bc0 · 2e00bc0
1 parent 477eb2f
commit 2e00bc0
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/tm2py/acceptance/observed.py b/tm2py/acceptance/observed.py
@@ -161,6 +161,8 @@ def __init__(
 
         if not on_board_assign_summary:
             self._validate()
+        elif on_board_assign_summary:
+            self._reduce_observed_rail_access_summaries()
 
     def _validate(self):
 
@@ -298,14 +300,10 @@ def _join_standard_route_id(self, input_df: pd.DataFrame) -> pd.DataFrame:
             how="left",
             left_on=["survey_operator", "survey_route", "time_period"],
             right_on=["survey_agency", "survey_route", "time_period"],
-        )
+        )  
 
         # observed records are not by direction, so we need to scale the boardings by 2
-        time_of_day_df["survey_boardings"] = np.where(
-            time_of_day_df["survey_operator"] == time_of_day_df["survey_route"],
-            time_of_day_df["survey_boardings"],
-            time_of_day_df["survey_boardings"] / 2.0,
-        )
+        time_of_day_df["survey_boardings"] = np.where(time_of_day_df["survey_operator"] == time_of_day_df["survey_route"], time_of_day_df["survey_boardings"], time_of_day_df["survey_boardings"]/2.0)
 
         return pd.concat([all_df, time_of_day_df], axis="rows", ignore_index=True)