alvaro/lol-analytics
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Increase default concurrency for facts processing
All checks were successful
ci / docker (push) Successful in 3m53s
Details

Browse Source
This commit is contained in:
Álvaro 2024-06-09 13:56:05 +02:00
parent ce825b75b1
commit 4e9d98afe2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex
View File

@ -21,7 +21,7 @@ defmodule LolAnalytics.Facts.FactsRunner do
] ]
end end
def peach(enum, fun, concurrency \\ 10, timeout \\ :infinity) do def peach(enum, fun, concurrency \\ 20, timeout \\ :infinity) do
Task.async_stream(enum, &fun.(&1), max_concurrency: concurrency, timeout: timeout) Task.async_stream(enum, &fun.(&1), max_concurrency: concurrency, timeout: timeout)
|> Stream.each(fn {:ok, val} -> val end) |> Stream.each(fn {:ok, val} -> val end)
|> Enum.to_list() |> Enum.to_list()