sorentwo

  def up do
    execute("LOCK TABLE oban_jobs")
    execute("CREATE TABLE oban_jobs_temp AS TABLE oban_jobs")
    execute("DROP TABLE oban_jobs CASCADE")

    flush()

    Oban.Migrations.up()
    Oban.Pro.Migrations.Workflow.up()
    Oban.Pro.Migrations.Batch.up()

sorentwo

execute """
CREATE TYPE oban_job_state AS ENUM (
  'available',
  'scheduled',
  'executing',
  'retryable',
  'completed',
  'cancelled',
  'discarded'
)

sorentwo

defmodule Oban.Pro.Repo do
  use Ecto.Repo, otp_app: :oban_pro, adapter: Ecto.Adapters.Postgres
end

Application.ensure_all_started(:postgrex)
Oban.Pro.Repo.start_link()

defmodule BenchWorker do
  @moduledoc false

sorentwo

defmodule Oban.Pro.Clouds.Gigalixir do
  @moduledoc """
  Cloud scaler for Gigalixir.

  ## Usage

  ```elixir
  alias Oban.Pro.DynamicScaler
  alias Oban.Pro.Clouds.Gigalixir

sorentwo

defmodule Oban.Pro.Clouds.EC2ASG do
  @behaviour Oban.Pro.Cloud

  @impl Oban.Pro.Cloud
  def init(opts), do: Map.new(opts)

  @impl Oban.Pro.Cloud
  def scale(desired, conf) do
    params = %{
      "Action" => "SetDesiredCapacity",

sorentwo

defmodule Oban.Pro.Clouds.Heroku do
  @moduledoc false

  @behaviour Oban.Pro.Cloud

  @enforce_keys [:app, :auth_token, :dyno]
  defstruct @enforce_keys

  @impl Oban.Pro.Cloud
  def init(opts) do

sorentwo

defmodule Oban.Pro.Clouds.Fly do
  @moduledoc false

  @behaviour Oban.Pro.Cloud

  @enforce_keys [:app_id, :auth_token, :regions]
  defstruct @enforce_keys

  @url "https://api.fly.io/graphql"

sorentwo

version: 2
updates:
- package-ecosystem: mix
  directory: "/"
  schedule:
    interval: daily
    time: "11:00"
  open-pull-requests-limit: 10
  insecure-external-code-execution: allow
  registries:

sorentwo

Migrating background jobs to Elixir is easy with Oban because everything lives in your PostgreSQL database. Oban relies on a structured oban_jobs table as its job queue, and purposefully uses portable data structures (JSON) for serialization. That makes it enqueueing jobs into Oban simple for any language with a PostgreSQL adapter, no Oban client necessary.

As a demonstration, let's explore inserting Oban jobs from a Rails application.

To start, define a skeletal ActiveRecord model with a few conveniences for scheduling jobs:

sorentwo

defmodule QueueBreaker do
  @moduledoc """
  Automatic queue pausing/resuming based on accumulated errors.
  
  ## Example
  
  Pause after 1000 errors:
  
      QueueBreaker.attach("risky-queue", 1000)
  """