WIP

lib/flame/fly_backend.ex

@@ -183,6 +183,8 @@ defmodule FLAME.FlyBackend do
 
     %FlyBackend{} = state = Map.merge(default, Map.new(provided_opts))
 
+    IO.inspect({opts, state.boot_timeout})
+
     for key <- [:token, :image, :host, :app] do
       unless Map.get(state, key) do
         raise ArgumentError, "missing :#{key} config for #{inspect(__MODULE__)}"

lib/flame/pool.ex

@@ -532,7 +532,7 @@ defmodule FLAME.Pool do
     cond do
       runner_count == 0 || !min_runner ||
           (min_runner.count == state.max_concurrency && runner_count < state.max) ->
-        if map_size(state.pending_runners) > 0 || state.async_boot_timer do
+        if state.async_boot_timer || map_size(state.pending_runners) * state.max_concurrency > Queue.size(state.waiting) do
           waiting_in(state, deadline, from)
         else
           state

test/fly_backend_test.exs

@@ -26,7 +26,7 @@ defmodule FLAME.FlyBackendTest do
     end
 
     assert_raise ArgumentError, ~r/missing :app/, fn ->
-      new({FlyBackend, token: "123", image: "img"})
+      new({FlyBackend, token: "123", image: "img", boot_timeout: 55123})
     end
 
     assert new({FlyBackend, token: "123", image: "img", app: "app"})