chore(bus): regen all dataset for waiver info (#715)

* bump bus events to get waiver id for historical

* backout runner changes that were unnecessary

Author: huangh

runners/run_parquet_hyper_lamp.py

@@ -15,8 +15,6 @@
 )
 from lamp_py.tableau.jobs.bus_performance import bus_schema
 from lamp_py.tableau.conversions.convert_bus_performance_data import apply_bus_analysis_conversions
-import copy
-
 
 from lamp_py.tableau.jobs.lamp_jobs import (
     LAMP_API_PROJECT,
@@ -37,27 +35,24 @@
     Prod_RailMetrics_CommuterRail_LongTerm,
 )
 
-TestProd_VehiclePositions_LightRailTerminals_60Day = copy.deepcopy(Prod_VehiclePositions_LightRailTerminals_60Day)
-TestProd_TripUpdates_LightRailTerminals_60Day = copy.deepcopy(Prod_TripUpdates_LightRailTerminals_60Day)
-TestProd_VehiclePositions_HeavyRailTerminals_30Day = copy.deepcopy(Prod_VehiclePositions_HeavyRailTerminals_30Day)
-TestProd_TripUpdates_HeavyRailTerminals_30Day = copy.deepcopy(Prod_TripUpdates_HeavyRailTerminals_30Day)
-TestProd_VehiclePositions_LightRail_7Day = copy.deepcopy(Prod_VehiclePositions_LightRail_7Day)
-TestDevGreen_VehiclePositions_LightRailTerminals_60Day = copy.deepcopy(
-    DevGreen_VehiclePositions_LightRailTerminals_60Day
-)
-TestDevGreen_TripUpdates_LightRailTerminals_60Day = copy.deepcopy(DevGreen_TripUpdates_LightRailTerminals_60Day)
-TestDevGreen_VehiclePositions_HeavyRailTerminals_60Day = copy.deepcopy(
-    DevGreen_VehiclePositions_HeavyRailTerminals_60Day
-)
-TestDevGreen_TripUpdates_HeavyRailTerminals_60Day = copy.deepcopy(DevGreen_TripUpdates_HeavyRailTerminals_60Day)
-TestProd_BusOperatorMapping_Recent = copy.deepcopy(Prod_BusOperatorMapping_Recent)
-TestProd_BusOperatorMapping_LongTerm = copy.deepcopy(Prod_BusOperatorMapping_LongTerm)
-TestProd_BusMetrics_Fall2025Rating = copy.deepcopy(Prod_BusMetrics_Fall2025Rating)
-TestProd_BusOperatorMapping_Fall2025Rating = copy.deepcopy(Prod_BusOperatorMapping_Fall2025Rating)
-TestProd_RailMetrics_Subway_LongTerm = copy.deepcopy(Prod_RailMetrics_Subway_LongTerm)
-TestProd_RailMetrics_CommuterRail_LongTerm = copy.deepcopy(Prod_RailMetrics_CommuterRail_LongTerm)
-TestHyperBusPerformanceRecent = copy.deepcopy(HyperBusPerformanceRecent)
-TestHyperBusPerformanceAll = copy.deepcopy(HyperBusPerformanceAll)
+TestProd_VehiclePositions_LightRailTerminals_60Day = Prod_VehiclePositions_LightRailTerminals_60Day
+TestProd_TripUpdates_LightRailTerminals_60Day = Prod_TripUpdates_LightRailTerminals_60Day
+TestProd_VehiclePositions_HeavyRailTerminals_30Day = Prod_VehiclePositions_HeavyRailTerminals_30Day
+TestProd_TripUpdates_HeavyRailTerminals_30Day = Prod_TripUpdates_HeavyRailTerminals_30Day
+TestProd_VehiclePositions_LightRail_7Day = Prod_VehiclePositions_LightRail_7Day
+TestDevGreen_VehiclePositions_LightRailTerminals_60Day = DevGreen_VehiclePositions_LightRailTerminals_60Day
+
+TestDevGreen_TripUpdates_LightRailTerminals_60Day = DevGreen_TripUpdates_LightRailTerminals_60Day
+TestDevGreen_VehiclePositions_HeavyRailTerminals_60Day = DevGreen_VehiclePositions_HeavyRailTerminals_60Day
+TestDevGreen_TripUpdates_HeavyRailTerminals_60Day = DevGreen_TripUpdates_HeavyRailTerminals_60Day
+TestProd_BusOperatorMapping_Recent = Prod_BusOperatorMapping_Recent
+TestProd_BusOperatorMapping_LongTerm = Prod_BusOperatorMapping_LongTerm
+TestProd_BusMetrics_Fall2025Rating = Prod_BusMetrics_Fall2025Rating
+TestProd_BusOperatorMapping_Fall2025Rating = Prod_BusOperatorMapping_Fall2025Rating
+TestProd_RailMetrics_Subway_LongTerm = Prod_RailMetrics_Subway_LongTerm
+TestProd_RailMetrics_CommuterRail_LongTerm = Prod_RailMetrics_CommuterRail_LongTerm
+TestHyperBusPerformanceRecent = HyperBusPerformanceRecent
+TestHyperBusPerformanceAll = HyperBusPerformanceAll
 
 yesterday = 1
 TestProd_VehiclePositions_LightRailTerminals_60Day.num_days_ago = yesterday

src/lamp_py/runtime_utils/remote_files.py

@@ -145,7 +145,7 @@ def s3_uri(self) -> str:
 )
 
 # published by LAMP
-bus_events = S3Location(bucket=S3_PUBLIC, prefix=os.path.join(LAMP, "bus_vehicle_events"), version="1.2")
+bus_events = S3Location(bucket=S3_PUBLIC, prefix=os.path.join(LAMP, "bus_vehicle_events"), version="1.2.1")
 bus_operator_mapping = S3Location(bucket=S3_ARCHIVE, prefix=os.path.join(LAMP, "bus_operator_mapping"), version="1.0")
 
 # Kinesis stream glides events