Packages

Oban-based runner adapter for the Hephaestus workflow engine. Durable jobs with retry/backoff, advisory lock serialization, and zero-contention parallel step execution via an auxiliary step_results table.

Current section

Files

Jump to
hephaestus_oban lib hephaestus_oban migrations postgres v02.ex
Raw

lib/hephaestus_oban/migrations/postgres/v02.ex

defmodule HephaestusOban.Migrations.Postgres.V02 do
@moduledoc false
use Ecto.Migration
def up(%{prefix: prefix}) do
alter table(:hephaestus_step_results, prefix: prefix) do
add_if_not_exists(:metadata_updates, :map, null: false, default: %{})
end
end
def down(%{prefix: prefix}) do
alter table(:hephaestus_step_results, prefix: prefix) do
remove_if_exists(:metadata_updates, :map)
end
end
end