diff --git a/lib/screens/last_trip/trip_updates/gtfs.ex b/lib/screens/last_trip/trip_updates/gtfs.ex index e1c42effd..806ead8ce 100644 --- 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 index a109349ec..e1d6db015 100644 --- 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)