diff --git a/apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex b/apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex index 537c952..688236d 100644 --- a/apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex +++ b/apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex @@ -21,7 +21,7 @@ defmodule LolAnalytics.Facts.FactsRunner do ] end - def peach(enum, fun, concurrency \\ 20, timeout \\ :infinity) do + def peach(enum, fun, concurrency \\ System.schedulers_online() * 2, timeout \\ :infinity) do Task.async_stream(enum, &fun.(&1), max_concurrency: concurrency, timeout: timeout) |> Stream.each(fn {:ok, val} -> val end) |> Enum.to_list() diff --git a/config/test.exs b/config/test.exs index 2149ad1..c2a6e2b 100644 --- a/config/test.exs +++ b/config/test.exs @@ -11,7 +11,7 @@ config :lol_analytics, LoLAnalytics.Repo, hostname: "localhost", database: "lol_analytics_test#{System.get_env("MIX_TEST_PARTITION")}", pool: Ecto.Adapters.SQL.Sandbox, - pool_size: System.schedulers_online() * 2 + pool_size: System.schedulers_online() * 4 # We don't run a server during test. If one is required, # you can enable the server option below.