update oban config

Author: zcesur

config/config.exs

@@ -41,13 +41,12 @@ config :algora, AlgoraWeb.Endpoint,
 
 config :algora, Oban,
   notifier: Oban.Notifiers.PG,
-  repo: Algora.ObanRepo,
-  get_dynamic_repo: {Algora.Repo, :oban_repo, []},
+  repo: Algora.Repo,
   queues: [
-    default: 1,
-    background: 1,
-    internal: 1,
-    internal_par: 5
+    default: [limit: 1, dispatch_cooldown: 5],
+    background: [limit: 1, dispatch_cooldown: 50],
+    internal: [limit: 1, dispatch_cooldown: 100],
+    internal_par: [limit: 1, dispatch_cooldown: 500]
   ]
 
 # Configures the mailer

config/dev.exs

@@ -33,15 +33,6 @@ config :algora, Algora.Repo,
   migration_primary_key: [type: :string],
   migration_timestamps: [type: :utc_datetime_usec]
 
-# Configure dedicated Oban database repository
-config :algora, Algora.ObanRepo,
-  url: System.get_env("DATABASE_URL"),
-  stacktrace: true,
-  show_sensitive_data_on_connection_error: true,
-  pool_size: 10,
-  migration_primary_key: [type: :string],
-  migration_timestamps: [type: :utc_datetime_usec]
-
 config :ex_aws,
   json_codec: Jason,
   access_key_id: System.get_env("AWS_ACCESS_KEY_ID"),

config/runtime.exs

@@ -55,21 +55,10 @@ if config_env() == :prod do
   config :algora, Algora.Repo,
     # ssl: true,
     url: database_url,
-    pool_size: String.to_integer(System.get_env("POOL_SIZE") || "10"),
+    pool_size: String.to_integer(System.get_env("POOL_SIZE") || "20"),
     socket_options: maybe_ipv6,
     migration_primary_key: [type: :string],
-    migration_timestamps: [type: :utc_datetime_usec],
-    queue_target: 5000
-
-  # Configure dedicated Oban database repository
-  config :algora, Algora.ObanRepo,
-    # ssl: true,
-    url: database_url,
-    pool_size: String.to_integer(System.get_env("OBAN_POOL_SIZE") || "10"),
-    socket_options: maybe_ipv6,
-    migration_primary_key: [type: :string],
-    migration_timestamps: [type: :utc_datetime_usec],
-    queue_target: 5000
+    migration_timestamps: [type: :utc_datetime_usec]
 
   config :ex_aws,
     json_codec: Jason,

config/test.exs

@@ -12,14 +12,6 @@ config :algora, Algora.Repo,
   migration_primary_key: [type: :string],
   migration_timestamps: [type: :utc_datetime_usec]
 
-# Configure dedicated Oban database repository for testing
-config :algora, Algora.ObanRepo,
-  url: System.get_env("TEST_DATABASE_URL"),
-  pool: Ecto.Adapters.SQL.Sandbox,
-  pool_size: System.schedulers_online() * 2,
-  migration_primary_key: [type: :string],
-  migration_timestamps: [type: :utc_datetime_usec]
-
 # We don't run a server during test. If one is required,
 # you can enable the server option below.
 config :algora, AlgoraWeb.Endpoint,

lib/algora/application.ex

@@ -14,7 +14,6 @@ defmodule Algora.Application do
       {NodeJS.Supervisor, [path: LiveSvelte.SSR.NodeJS.server_path(), pool_size: 4]},
       AlgoraWeb.Telemetry,
       Algora.Repo,
-      Algora.ObanRepo,
       {Oban, Application.fetch_env!(:algora, Oban)},
       {DNSCluster, query: Application.get_env(:algora, :dns_cluster_query) || :ignore},
       {Phoenix.PubSub, name: Algora.PubSub},

lib/algora/repo.ex

@@ -3,14 +3,6 @@ defmodule Algora.Repo do
     otp_app: :algora,
     adapter: Ecto.Adapters.Postgres
 
-  def oban_repo do
-    if in_transaction?() do
-      __MODULE__
-    else
-      Algora.ObanRepo
-    end
-  end
-
   alias Algora.Activities.Activity
   alias Algora.Activities.Notifier