From 0987290dca6433c268f8a1c192f3b58bedb391ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro?= Date: Sun, 9 Jun 2024 14:15:37 +0200 Subject: [PATCH] update pool size and concurrency default value for facts runner --- apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex | 2 +- config/test.exs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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.