update pool size and concurrency default value for facts runner

2024-06-09 14:15:37 +02:00
parent 4e9d98afe2
commit 0987290dca
2 changed files with 2 additions and 2 deletions
@@ -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()