Only queue new jobs if there aren't currently available or executing

orcasound · Jul 1, 2024 · 3b004c1 · 3b004c1
1 parent b39a3bc
commit 3b004c1
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/server/lib/orcasite/radio/workers/link_feed_stream.ex b/server/lib/orcasite/radio/workers/link_feed_stream.ex
@@ -1,5 +1,11 @@
 defmodule Orcasite.Radio.Workers.LinkFeedStream do
- use Oban.Worker, queue: :feeds, unique: [keys: [:feed_stream_id], period: 10]
+ use Oban.Worker,
+ queue: :feeds,
+ unique: [
+ keys: [:feed_stream_id],
+ period: :infinity,
+ states: [:available, :scheduled, :executing]
+ ]
 
  @impl Oban.Worker
  def perform(%Oban.Job{args: %{"feed_stream_id" => nil} = args}) do

diff --git a/server/lib/orcasite/radio/workers/update_feed_segments.ex b/server/lib/orcasite/radio/workers/update_feed_segments.ex
@@ -1,5 +1,7 @@
 defmodule Orcasite.Radio.Workers.UpdateFeedSegments do
- use Oban.Worker, queue: :feeds, unique: [keys: [:feed_stream_id], period: 10]
+ use Oban.Worker,
+ queue: :feeds,
+ unique: [keys: [:feed_stream_id], period: :infinity, states: [:available, :scheduled, :executing]]
 
  @impl Oban.Worker
  def perform(%Oban.Job{args: %{"feed_stream_id" => feed_stream_id}}) do