diff --git a/lib/music_library/records/importer.ex b/lib/music_library/records/importer.ex index b0cdf6e4..4b02718d 100644 --- a/lib/music_library/records/importer.ex +++ b/lib/music_library/records/importer.ex @@ -73,16 +73,12 @@ defmodule MusicLibrary.Records.Importer do def import_all_cover_images do Rec |> MusicLibrary.Repo.all() - |> Task.async_stream( - fn r -> - if r.image_data == nil do - import_cover_image(r) - IO.puts("Imported cover image for #{r.title}") - end - end, - timeout: 10_000 - ) - |> Stream.run() + |> Enum.each(fn r -> + if r.image_data == nil do + import_cover_image(r) + IO.puts("Imported cover image for #{r.title}") + end + end) end def import_all do