use numpy.issubdtype for a more expansive type check, was not matching int32

Author: edasmalchi

rt_segment_speeds/logs/interpolate_stop_arrival.log

@@ -72,3 +72,4 @@ interpolate arrivals for stop_segments 2024-12-11:  2024-12-11: 0:14:09.409333
 2025-11-17 13:14:59.585 | INFO     | interpolate_stop_arrival:interpolate_stop_arrivals:236 - interpolate arrivals for speedmap_segments 2025-11-05:  2025-11-05: 0:02:47.025833
 2025-11-17 15:24:22.306 | INFO     | interpolate_stop_arrival:interpolate_stop_arrivals:236 - interpolate arrivals for rt_stop_times 2025-11-05:  2025-11-05: 0:10:51.471830
 2025-11-17 15:43:37.574 | INFO     | interpolate_stop_arrival:interpolate_stop_arrivals:236 - interpolate arrivals for speedmap_segments 2025-11-05:  2025-11-05: 0:02:35.503949
+2026-02-02 18:13:27.813 | INFO     | interpolate_stop_arrival:interpolate_stop_arrivals:181 - interpolate arrivals for rt_stop_times 2025-12-17:  2025-12-17: 0:09:55.360755

rt_segment_speeds/logs/nearest_vp.log

@@ -78,3 +78,4 @@
 2026-01-23 11:57:11.887 | INFO     | nearest_vp_to_stop:nearest_neighbor_for_stop:147 - nearest neighbor for rt_stop_times 2025-12-17: 0:39:47.419228
 2026-02-02 16:13:13.661 | INFO     | nearest_vp_to_stop:nearest_neighbor_for_stop:149 - nearest neighbor for rt_stop_times 2025-12-17: 0:41:58.668677
 2026-02-02 17:13:09.915 | INFO     | nearest_vp_to_stop:nearest_neighbor_for_stop:149 - nearest neighbor for rt_stop_times 2025-12-17: 0:43:15.982834
+2026-02-02 18:03:32.371 | INFO     | nearest_vp_to_stop:nearest_neighbor_for_stop:149 - nearest neighbor for rt_stop_times 2025-12-17: 0:42:34.619619

rt_segment_speeds/scripts/stop_arrivals_to_speed.py

@@ -110,18 +110,11 @@ def calculate_speed_from_stop_arrivals(
         subseq_stop_meters=(df.groupby(trip_cols, observed=True, group_keys=False).stop_meters.shift(-1)),
     )
 
-    speed = (
-        df.assign(
-            meters_elapsed=df.subseq_stop_meters - df.stop_meters,
-            sec_elapsed=df.subseq_arrival_time_sec - df.arrival_time_sec,
-        )
-        .pipe(
-            segment_calcs.derive_speed,
-            ("stop_meters", "subseq_stop_meters"),
-            ("arrival_time_sec", "subseq_arrival_time_sec"),
-        )
-        .pipe(attach_operator_natural_identifiers, analysis_date, segment_type)
-    )
+    speed = df.pipe(
+        segment_calcs.derive_speed,
+        ("stop_meters", "subseq_stop_meters"),
+        ("arrival_time_sec", "subseq_arrival_time_sec"),
+    ).pipe(attach_operator_natural_identifiers, analysis_date, segment_type)
 
     gcs_pandas().data_frame_to_parquet(speed, f"{SEGMENT_GCS}{SPEED_FILE}.parquet")