unify job queues to use default and internal categories

zcesur · zcesur · commit cd69e77317bc · 2025-08-02T21:07:57.000+03:00
diff --git a/config/config.exs b/config/config.exs
@@ -44,26 +44,10 @@ config :algora, Oban,
   repo: Algora.ObanRepo,
   get_dynamic_repo: {Algora.Repo, :oban_repo, []},
   queues: [
-    # --- #
-    event_consumers: 1,
-    comment_consumers: 1,
-    search_consumers: 1,
-    delivery_consumers: 1,
-    notify_bounty: 1,
-    notify_tip_intent: 1,
-    notify_claim: 1,
-    transfers: 1,
-    activity_notifier: 1,
-    activity_mailer: 1,
-    campaign_emails: 1,
-    fetch_top_contributions: 1,
-    job_invitations: 1,
-    # --- #
-    github_og_image: 1,
-    notify_transfer: 1,
-    prompt_payout_connect: 1,
-    activity_discord: 1,
-    sync_contribution: 5
+    default: 1,
+    background: 1,
+    internal: 1,
+    internal_par: 5
   ]
 
 # Configures the mailer
diff --git a/lib/algora/activities/jobs/notifier.ex b/lib/algora/activities/jobs/notifier.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Activities.Notifier do
   @moduledoc false
   use Oban.Worker,
-    queue: :activity_notifier,
+    queue: :background,
     max_attempts: 1
 
   alias Algora.Activities
diff --git a/lib/algora/activities/jobs/send_discord.ex b/lib/algora/activities/jobs/send_discord.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Activities.SendDiscord do
   @moduledoc false
   use Oban.Worker,
-    queue: :activity_discord,
+    queue: :background,
     tags: ["discord", "activities"]
 
   require Logger
diff --git a/lib/algora/activities/jobs/send_email.ex b/lib/algora/activities/jobs/send_email.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Activities.SendEmail do
   @moduledoc false
   use Oban.Worker,
-    queue: :activity_mailer,
+    queue: :background,
     max_attempts: 1,
     tags: ["email", "activities"]
 
diff --git a/lib/algora/bounties/jobs/notify_bounty.ex b/lib/algora/bounties/jobs/notify_bounty.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Bounties.Jobs.NotifyBounty do
   @moduledoc false
   use Oban.Worker,
-    queue: :notify_bounty,
+    queue: :default,
     max_attempts: 1
 
   alias Algora.Bounties
diff --git a/lib/algora/bounties/jobs/notify_claim.ex b/lib/algora/bounties/jobs/notify_claim.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Bounties.Jobs.NotifyClaim do
   @moduledoc false
-  use Oban.Worker, queue: :notify_claim
+  use Oban.Worker, queue: :default
 
   import Ecto.Query
 
diff --git a/lib/algora/bounties/jobs/notify_tip_intent.ex b/lib/algora/bounties/jobs/notify_tip_intent.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Bounties.Jobs.NotifyTipIntent do
   @moduledoc false
-  use Oban.Worker, queue: :notify_tip_intent
+  use Oban.Worker, queue: :default
 
   alias Algora.Github
 
diff --git a/lib/algora/bounties/jobs/notify_transfer.ex b/lib/algora/bounties/jobs/notify_transfer.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Bounties.Jobs.NotifyTransfer do
   @moduledoc false
-  use Oban.Worker, queue: :notify_transfer
+  use Oban.Worker, queue: :default
 
   import Ecto.Query
 
diff --git a/lib/algora/bounties/jobs/prompt_payout_connect.ex b/lib/algora/bounties/jobs/prompt_payout_connect.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Bounties.Jobs.PromptPayoutConnect do
   @moduledoc false
-  use Oban.Worker, queue: :prompt_payout_connect
+  use Oban.Worker, queue: :default
 
   import Ecto.Query
 
diff --git a/lib/algora/integrations/github/poller/delivery_consumer.ex b/lib/algora/integrations/github/poller/delivery_consumer.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Github.Poller.DeliveryConsumer do
   @moduledoc false
-  use Oban.Worker, queue: :delivery_consumers
+  use Oban.Worker, queue: :background
 
   import Ecto.Query
 
diff --git a/lib/algora/integrations/github/poller/search_consumer.ex b/lib/algora/integrations/github/poller/search_consumer.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Github.Poller.SearchConsumer do
   @moduledoc false
-  use Oban.Worker, queue: :search_consumers
+  use Oban.Worker, queue: :background
 
   alias Algora.Accounts
   alias Algora.Bounties
diff --git a/lib/algora/payments/jobs/execute_pending_transfers.ex b/lib/algora/payments/jobs/execute_pending_transfers.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Payments.Jobs.ExecutePendingTransfer do
   @moduledoc false
   use Oban.Worker,
-    queue: :transfers,
+    queue: :default,
     unique: [period: :infinity]
 
   alias Algora.Payments
diff --git a/lib/algora/workspace/jobs/fetch_top_contributions.ex b/lib/algora/workspace/jobs/fetch_top_contributions.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.FetchTopContributions do
   @moduledoc false
   use Oban.Worker,
-    queue: :fetch_top_contributions,
+    queue: :internal,
     max_attempts: 2,
     unique: [period: 30 * 24 * 60 * 60, fields: [:args]]
 
diff --git a/lib/algora/workspace/jobs/import_contributor.ex b/lib/algora/workspace/jobs/import_contributor.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.ImportContributor do
   @moduledoc false
   use Oban.Worker,
-    queue: :fetch_top_contributions,
+    queue: :internal,
     max_attempts: 3
 
   alias Algora.Github
diff --git a/lib/algora/workspace/jobs/import_stargazer.ex b/lib/algora/workspace/jobs/import_stargazer.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.ImportStargazer do
   @moduledoc false
   use Oban.Worker,
-    queue: :fetch_top_contributions,
+    queue: :internal,
     max_attempts: 3
 
   alias Algora.Github
diff --git a/lib/algora/workspace/jobs/process_contributors.ex b/lib/algora/workspace/jobs/process_contributors.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.ProcessContributors do
   @moduledoc false
   use Oban.Worker,
-    queue: :sync_contribution,
+    queue: :internal_par,
     max_attempts: 3
 
   alias Algora.Workspace.Jobs.ImportContributor
diff --git a/lib/algora/workspace/jobs/process_stargazers.ex b/lib/algora/workspace/jobs/process_stargazers.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.ProcessStargazers do
   @moduledoc false
   use Oban.Worker,
-    queue: :sync_contribution,
+    queue: :internal_par,
     max_attempts: 3
 
   import Ecto.Query
diff --git a/lib/algora/workspace/jobs/sync_contribution.ex b/lib/algora/workspace/jobs/sync_contribution.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.SyncContribution do
   @moduledoc false
   use Oban.Worker,
-    queue: :sync_contribution,
+    queue: :internal_par,
     max_attempts: 2
 
   alias Algora.Github
diff --git a/lib/algora/workspace/jobs/sync_user.ex b/lib/algora/workspace/jobs/sync_user.ex
@@ -1,7 +1,7 @@
 defmodule Algora.Workspace.Jobs.SyncUser do
   @moduledoc false
   use Oban.Worker,
-    queue: :sync_contribution,
+    queue: :internal_par,
     max_attempts: 3
 
   import Ecto.Changeset
diff --git a/lib/algora/workspace/jobs/update_repository_og_image.ex b/lib/algora/workspace/jobs/update_repository_og_image.ex
@@ -1,6 +1,6 @@
 defmodule Algora.Workspace.Jobs.UpdateRepositoryOgImage do
   @moduledoc false
-  use Oban.Worker, queue: :github_og_image
+  use Oban.Worker, queue: :internal
 
   alias Algora.Repo
   alias Algora.Workspace.Repository
