Uniform repo usage for Oban jobs
This commit is contained in:
@@ -3,8 +3,8 @@ defmodule MusicLibrary.Artists do
|
|||||||
|
|
||||||
alias MusicLibrary.Artists.ArtistInfo
|
alias MusicLibrary.Artists.ArtistInfo
|
||||||
alias MusicLibrary.Assets
|
alias MusicLibrary.Assets
|
||||||
alias MusicLibrary.{BackgroundRepo, Repo, Worker}
|
|
||||||
alias MusicLibrary.Records.{ArtistRecord, Record}
|
alias MusicLibrary.Records.{ArtistRecord, Record}
|
||||||
|
alias MusicLibrary.{Repo, Worker}
|
||||||
|
|
||||||
def get_artist!(musicbrainz_id) do
|
def get_artist!(musicbrainz_id) do
|
||||||
q =
|
q =
|
||||||
@@ -226,6 +226,6 @@ defmodule MusicLibrary.Artists do
|
|||||||
end
|
end
|
||||||
|
|
||||||
defp enqueue_worker(worker, params) do
|
defp enqueue_worker(worker, params) do
|
||||||
params |> worker.new(meta: %{}) |> BackgroundRepo.insert()
|
params |> worker.new(meta: %{}) |> Oban.insert()
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -7,8 +7,8 @@ defmodule MusicLibrary.Records do
|
|||||||
|
|
||||||
alias MusicLibrary.Artists
|
alias MusicLibrary.Artists
|
||||||
alias MusicLibrary.Assets
|
alias MusicLibrary.Assets
|
||||||
alias MusicLibrary.{BackgroundRepo, Repo, Worker}
|
|
||||||
alias MusicLibrary.Records.{ArtistRecord, Record, SearchIndex, SearchParser}
|
alias MusicLibrary.Records.{ArtistRecord, Record, SearchIndex, SearchParser}
|
||||||
|
alias MusicLibrary.{Repo, Worker}
|
||||||
|
|
||||||
def essential_fields do
|
def essential_fields do
|
||||||
SearchIndex.__schema__(:fields)
|
SearchIndex.__schema__(:fields)
|
||||||
@@ -431,7 +431,7 @@ defmodule MusicLibrary.Records do
|
|||||||
end
|
end
|
||||||
|
|
||||||
defp enqueue_worker(worker, params, meta) do
|
defp enqueue_worker(worker, params, meta) do
|
||||||
params |> worker.new(meta: meta) |> BackgroundRepo.insert()
|
params |> worker.new(meta: meta) |> Oban.insert()
|
||||||
end
|
end
|
||||||
|
|
||||||
defp record_meta(record) do
|
defp record_meta(record) do
|
||||||
|
|||||||
Reference in New Issue
Block a user