diff options
Diffstat (limited to 'lib/poolparty/scheduler.ex')
| -rw-r--r-- | lib/poolparty/scheduler.ex | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/poolparty/scheduler.ex b/lib/poolparty/scheduler.ex index dc9e1b3..dc4d731 100644 --- a/lib/poolparty/scheduler.ex +++ b/lib/poolparty/scheduler.ex @@ -30,6 +30,11 @@ defmodule PoolParty.Scheduler do GenServer.cast(__MODULE__, {:ready, result, worker_pid}) end + def leave(worker_pid) do + Logger.debug("[#{__MODULE__}]: Worker leaving pool") + GenServer.cast(__MODULE__, {:leave, worker_pid}) + end + def process(func, args, from) do Logger.debug("[#{__MODULE__}]: Casting work request") GenServer.cast(__MODULE__, {:process, func, args, from}) |