diff --git a/lib/oban/engines/dolphin.ex b/lib/oban/engines/dolphin.ex index 669e6342..3a061a33 100644 --- a/lib/oban/engines/dolphin.ex +++ b/lib/oban/engines/dolphin.ex @@ -270,7 +270,6 @@ defmodule Oban.Engines.Dolphin do queryable |> where([j], j.state not in ~w(cancelled completed discarded)) |> select([j], map(j, [:id, :queue, :state])) - |> lock("FOR UPDATE SKIP LOCKED") |> then(&Repo.all(conf, &1)) query = where(Job, [j], j.id in ^Enum.map(jobs, & &1.id))