Flow causing zombie jobs in Oban
Section
import Ecto.Query
alias ObanTrap.Repo
alias ObanTrap.Worker
{:ok, %{id: id}} = %{type: :spawn_link} |> Worker.new() |> Oban.insert()
Repo.all(from(j in "oban_jobs", where: j.id == ^id, select: j.state))
{:ok, %{id: id}} = %{type: :flow} |> Worker.new() |> Oban.insert()
Repo.all(from(j in "oban_jobs", where: j.id == ^id, select: j.state))
id