From d603bc2ffdda8b6f85fe868de594e3eeb1fbbf89 Mon Sep 17 00:00:00 2001 From: Claudio Ortolina Date: Sun, 27 Apr 2025 21:23:13 +0100 Subject: [PATCH] Define a queue for heavy writes --- config/config.exs | 2 +- lib/music_library/worker/fetch_artist_image.ex | 2 +- lib/music_library/worker/refresh_cover.ex | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/config/config.exs b/config/config.exs index e96efde5..1e4d5109 100644 --- a/config/config.exs +++ b/config/config.exs @@ -80,7 +80,7 @@ config :error_tracker, config :music_library, Oban, engine: Oban.Engines.Lite, - queues: [default: 10], + queues: [default: 10, heavy_writes: 1], repo: MusicLibrary.BackgroundRepo config :music_library, MusicLibrary.ErrorRepo, priv: "priv/error_repo" diff --git a/lib/music_library/worker/fetch_artist_image.ex b/lib/music_library/worker/fetch_artist_image.ex index 868a8e9e..eab8a70b 100644 --- a/lib/music_library/worker/fetch_artist_image.ex +++ b/lib/music_library/worker/fetch_artist_image.ex @@ -1,5 +1,5 @@ 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 def perform(%Oban.Job{args: %{"id" => artist_id}}) do diff --git a/lib/music_library/worker/refresh_cover.ex b/lib/music_library/worker/refresh_cover.ex index 14f0f146..a784a2e4 100644 --- a/lib/music_library/worker/refresh_cover.ex +++ b/lib/music_library/worker/refresh_cover.ex @@ -1,5 +1,5 @@ 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 def perform(%Oban.Job{args: %{"id" => record_id}}) do