projects
/
akkoma
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
55affbc
)
cleanup
author
Egor Kislitsyn
<egor@kislitsyn.com>
Mon, 28 Jan 2019 16:12:02 +0000
(23:12 +0700)
committer
Egor Kislitsyn
<egor@kislitsyn.com>
Mon, 28 Jan 2019 16:12:02 +0000
(23:12 +0700)
lib/pleroma/jobs.ex
patch
|
blob
|
history
diff --git
a/lib/pleroma/jobs.ex
b/lib/pleroma/jobs.ex
index dff0f21970414cdfdb3308286817273d8000bc18..2a75ff529a59c6097be6482fdae5684e841d87bc 100644
(file)
--- a/
lib/pleroma/jobs.ex
+++ b/
lib/pleroma/jobs.ex
@@
-40,7
+40,7
@@
defmodule Pleroma.Jobs do
## Arguments
- `queue_name` - a queue name(must be specified in the config).
## Arguments
- `queue_name` - a queue name(must be specified in the config).
- - `mod` - a worker module
, must have `perform` function
.
+ - `mod` - a worker module
(must have `perform` function)
.
- `args` - a list of arguments for the `perform` function of the worker module.
- `priority` - a job priority (`0` by default).
- `args` - a list of arguments for the `perform` function of the worker module.
- `priority` - a job priority (`0` by default).
@@
-76,7
+76,6
@@
defmodule Pleroma.Jobs do
apply(mod, :perform, args)
end
else
apply(mod, :perform, args)
end
else
- @spec enqueue(atom(), atom(), [any()], integer()) :: :ok
def enqueue(queue_name, mod, args, priority \\ 1) do
GenServer.cast(__MODULE__, {:enqueue, queue_name, mod, args, priority})
end
def enqueue(queue_name, mod, args, priority \\ 1) do
GenServer.cast(__MODULE__, {:enqueue, queue_name, mod, args, priority})
end
@@
-95,11
+94,6
@@
defmodule Pleroma.Jobs do
{:noreply, state}
end
{:noreply, state}
end
- def handle_cast(m, state) do
- IO.inspect("Unknown: #{inspect(m)}, #{inspect(state)}")
- {:noreply, state}
- end
-
def handle_info({:DOWN, ref, :process, _pid, _reason}, state) do
queue_name = state.refs[ref]
def handle_info({:DOWN, ref, :process, _pid, _reason}, state) do
queue_name = state.refs[ref]