Retry fetching LastTrip info before crashing.

mbta · Nov 22, 2024 · 912d745 · 912d745
1 parent 0f80384
commit 912d745
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/screens/last_trip/trip_updates/gtfs.ex b/lib/screens/last_trip/trip_updates/gtfs.ex
@@ -5,7 +5,10 @@ defmodule Screens.LastTrip.TripUpdates.GTFS do
   """
   @behaviour Screens.LastTrip.TripUpdates
 
+  use Retry.Annotation
+
   @impl true
+  @retry with: Stream.take(constant_backoff(500), 5)
   def get do
     trip_updates_url = Application.fetch_env!(:screens, :trip_updates_url)
 

diff --git a/lib/screens/last_trip/vehicle_positions/gtfs.ex b/lib/screens/last_trip/vehicle_positions/gtfs.ex
@@ -5,7 +5,10 @@ defmodule Screens.LastTrip.VehiclePositions.GTFS do
   """
   @behaviour Screens.LastTrip.VehiclePositions
 
+  use Retry.Annotation
+
   @impl true
+  @retry with: Stream.take(constant_backoff(500), 5)
   def get do
     vehicle_positions_url = Application.fetch_env!(:screens, :vehicle_positions_url)