martincabrera

with {:ok, algorithm_result} <- PythonWorker.call(json_input),
        {:ok, stacks} <- Jason.decode(algorithm_result) do
     {:ok, stacks}
end

martincabrera

def handle_call({:optimize, json_input}, _from, pid) do
   result = :python.call(pid, :optimize, :optimize, [json_input])
   {:reply, {:ok, result}, pid}
end

martincabrera

def call(json_input) do
   Task.async(fn ->
     :poolboy.transaction(
       :worker,
       fn pid ->
         GenServer.call(pid, {:optimize, json_input})
       end,
       @timeout
     )
   end)

martincabrera

# Define workers and child supervisors to be supervised
   children = [
     # Poolboy python initialization
     :poolboy.child_spec(:worker, python_poolboy_config())
   ]

 defp python_poolboy_config do
   [
     {:name, {:local, :worker}},
     {:worker_module, Monocle.AutoStacking.PythonWorker},

martincabrera

{:poolboy, "~> 1.5"}

martincabrera

result = :python.call(pid, :optimize, :optimize, [json_input])

martincabrera

{:ok, pid} = :python.start([{:python_path, to_charlist(path)}, {:python, 'python3'}])

martincabrera

path = [:code.priv_dir(:monocle), "python"] |> Path.join()

martincabrera

{:erlport, "~> 0.10.1"}