diff --git a/lib/trinity/scheduler.ex b/lib/trinity/scheduler.ex index 7b4262e..2cbae3c 100644 --- a/lib/trinity/scheduler.ex +++ b/lib/trinity/scheduler.ex @@ -354,12 +354,12 @@ defmodule Trinity.Scheduler do # Note that we do not currently bother to destroy aliases here case :ets.lookup(proc_queue_keys, pid) do - [{:timeout_infinity, _ref}] -> + [{_key, {:timeout_infinity, _ref}}] -> :ets.delete(proc_queue_keys, pid) - [{:timeout, _ref, qk}] -> + [{_key, {:timeout, _ref, qk}}] -> :ets.delete(queue, qk) :ets.delete(proc_queue_keys, pid) - [{:resume, qk}] -> + [{_key, {:resume, qk}}] -> :ets.delete(queue, qk) :ets.delete(proc_queue_keys, pid) _ -> :noop