diff --git a/server/lib/orcasite/radio/feed_stream.ex b/server/lib/orcasite/radio/feed_stream.ex index 4bdef0d4..bbb7588d 100644 --- a/server/lib/orcasite/radio/feed_stream.ex +++ b/server/lib/orcasite/radio/feed_stream.ex @@ -88,7 +88,8 @@ defmodule Orcasite.Radio.FeedStream do :cloudfront_url, :playlist_path, :playlist_m3u8_path, - :playlist_timestamp + :playlist_timestamp, + :updated_at ] argument :m3u8_path, :string, allow_nil?: false @@ -172,7 +173,8 @@ defmodule Orcasite.Radio.FeedStream do :bucket, :bucket_region, :cloudfront_url, - :playlist_timestamp + :playlist_timestamp, + :updated_at ] accept [ diff --git a/server/lib/orcasite/radio/feed_stream_queue.ex b/server/lib/orcasite/radio/feed_stream_queue.ex index 7ca5ea2f..6f4b5a5d 100644 --- a/server/lib/orcasite/radio/feed_stream_queue.ex +++ b/server/lib/orcasite/radio/feed_stream_queue.ex @@ -56,7 +56,10 @@ defmodule Orcasite.Radio.FeedStreamQueue do end) Task.Supervisor.start_child(Orcasite.TaskSupervisor, fn -> - Orcasite.Radio.bulk_create(paths, Orcasite.Radio.FeedStream, :from_m3u8_path) + Orcasite.Radio.bulk_create(paths, Orcasite.Radio.FeedStream, :from_m3u8_path, + return_errors?: true, + stop_on_error?: true + ) end) messages