add TripId to TripKey

mbta · Oct 25, 2024 · daa0ff0 · daa0ff0
1 parent 1b98406
commit daa0ff0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/lamp_py/ingestion/glides.py b/src/lamp_py/ingestion/glides.py
@@ -273,6 +273,7 @@ def event_schema(self) -> pyarrow.schema:
         glides_trip_key = pyarrow.struct(
             [
                 ("serviceDate", pyarrow.string()),
+                ("tripId", pyarrow.string()),
                 ("startLocation", self.glides_location),
                 ("endLocation", self.glides_location),
                 ("startTime", pyarrow.string()),