mirror of
https://github.com/ash-project/ash.git
synced 2024-09-20 13:33:20 +12:00
fix: don't throw away timeout exit
This commit is contained in:
parent
20a9f76c8d
commit
25f5a27525
1 changed files with 5 additions and 1 deletions
|
@ -247,7 +247,7 @@ defmodule Ash.Engine do
|
||||||
#{Enum.map_join(opts[:requests], "\n", &summarize(&1))}
|
#{Enum.map_join(opts[:requests], "\n", &summarize(&1))}
|
||||||
""")
|
""")
|
||||||
|
|
||||||
exit(:timeout)
|
exit(:engine_timeout)
|
||||||
end
|
end
|
||||||
end)
|
end)
|
||||||
end
|
end
|
||||||
|
@ -478,6 +478,10 @@ defmodule Ash.Engine do
|
||||||
|> maybe_shutdown()
|
|> maybe_shutdown()
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def handle_info({:DOWN, _, _, _, :engine_timeout}, _state) do
|
||||||
|
exit(:timeout)
|
||||||
|
end
|
||||||
|
|
||||||
def handle_info({:DOWN, _, _, _pid, {:error, error, %Request{} = request}}, state) do
|
def handle_info({:DOWN, _, _, _pid, {:error, error, %Request{} = request}}, state) do
|
||||||
state
|
state
|
||||||
|> log(fn -> "Request exited in failure #{request.name}: #{inspect(error)}" end)
|
|> log(fn -> "Request exited in failure #{request.name}: #{inspect(error)}" end)
|
||||||
|
|
Loading…
Reference in a new issue