cloud/music_library
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Define a queue for heavy writes

Browse Source
This commit is contained in:
Claudio Ortolina
2025-04-27 21:23:13 +01:00
parent f5b783bdff
commit d603bc2ffd
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
config/config.exs
+1 -1
View File
@@ -80,7 +80,7 @@ config :error_tracker,
config :music_library, Oban, config :music_library, Oban,
engine: Oban.Engines.Lite, engine: Oban.Engines.Lite,
queues: [default: 10], queues: [default: 10, heavy_writes: 1],
repo: MusicLibrary.BackgroundRepo repo: MusicLibrary.BackgroundRepo
config :music_library, MusicLibrary.ErrorRepo, priv: "priv/error_repo" config :music_library, MusicLibrary.ErrorRepo, priv: "priv/error_repo"
lib/music_library/worker/fetch_artist_image.ex
+1 -1
View File
@@ -1,5 +1,5 @@
defmodule MusicLibrary.Worker.FetchArtistImage do defmodule MusicLibrary.Worker.FetchArtistImage do
use Oban.Worker, queue: :default, max_attempts: 3 use Oban.Worker, queue: :heavy_writes, max_attempts: 3
@impl Oban.Worker @impl Oban.Worker
def perform(%Oban.Job{args: %{"id" => artist_id}}) do def perform(%Oban.Job{args: %{"id" => artist_id}}) do
lib/music_library/worker/refresh_cover.ex
+1 -1
View File
@@ -1,5 +1,5 @@
defmodule MusicLibrary.Worker.RefreshCover do defmodule MusicLibrary.Worker.RefreshCover do
use Oban.Worker, queue: :default, max_attempts: 3 use Oban.Worker, queue: :heavy_writes, max_attempts: 3
@impl Oban.Worker @impl Oban.Worker
def perform(%Oban.Job{args: %{"id" => record_id}}) do def perform(%Oban.Job{args: %{"id" => record_id}}) do