Powered by AppSignal & Oban Pro
Would you like to see your link here? Contact us

Flow causing zombie jobs in Oban

notebooks/test.livemd

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