diff options
| author | Egor Kislitsyn <egor@kislitsyn.com> | 2019-01-30 22:56:59 +0700 |
|---|---|---|
| committer | Egor Kislitsyn <egor@kislitsyn.com> | 2019-01-30 22:56:59 +0700 |
| commit | ab31adf15bbec1597a9b7cf065898fb3f712eef3 (patch) | |
| tree | 4223e2d1291a1b519351ff9a56e48f535160d8d8 | |
| parent | 1724a6b34b099dc83b94687d27d2492aaf97013e (diff) | |
| download | pleroma-ab31adf15bbec1597a9b7cf065898fb3f712eef3.tar.gz | |
tiny improve
| -rw-r--r-- | lib/pleroma/jobs.ex | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/pleroma/jobs.ex b/lib/pleroma/jobs.ex index 16dccb682..24b7e5e46 100644 --- a/lib/pleroma/jobs.ex +++ b/lib/pleroma/jobs.ex @@ -102,7 +102,11 @@ defmodule Pleroma.Jobs do running_jobs = :sets.del_element(ref, running_jobs) - state = state |> remove_ref(ref) |> maybe_start_job(queue_name, running_jobs, queue) + state = + state + |> remove_ref(ref) + |> update_queue(queue_name, {running_jobs, queue}) + |> maybe_start_job(queue_name, running_jobs, queue) {:noreply, state} end @@ -118,7 +122,7 @@ defmodule Pleroma.Jobs do |> add_ref(queue_name, mref) |> update_queue(queue_name, {:sets.add_element(mref, running_jobs), queue}) else - update_queue(state, queue_name, {running_jobs, queue}) + state end end |