prog/data_mover.py

@@ -10,7 +10,7 @@ import admin_server
 import data_utils
 
 async def main():
-    s = await communication.SSHRunSocket().connect('ssh jiri@hluk.fnuk.eu /mnt/jr/prog/run_py admin_server.py')
+    s = await communication.SSHRunSocket().connect('ssh jr@hluk.fnuk.eu /mnt/jr/prog/run_py admin_server.py')
     c = admin_server.AdminServer(s)
     for dt in await c.list_realtime_data(datetime.datetime(2023, 1, 1, 0, 0), datetime.datetime(2100, 1, 1, 0, 0)):
         path = "data/realtime/"+dt_to_path(dt)

prog/data_utils.py

@@ -110,6 +110,8 @@ class TripHistory:
 
     async def load_gtfs_shape(self):
         self.gtfs_shape = await gtfs.for_date(self.trip.date).get_shape_for_trip_id(self.trip.trip_id)
+        if self.gtfs_shape is not None:
+            assert len(self.gtfs_shape), f"Zero len shape for {self.trip.date} {self.trip.trip_id}"
 
 
     async def load_history(self, dt_from, dt_to):