From 4e9d98afe2f12568fa79309b11a7ec65be350b00 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro?= Date: Sun, 9 Jun 2024 13:56:05 +0200 Subject: [PATCH] Increase default concurrency for facts processing --- apps/lol_analytics/lib/lol_analytics/facts/facts_runner.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 05686b6..537c952 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 \\ 10, timeout \\ :infinity) do + def peach(enum, fun, concurrency \\ 20, timeout \\ :infinity) do Task.async_stream(enum, &fun.(&1), max_concurrency: concurrency, timeout: timeout) |> Stream.each(fn {:ok, val} -> val end) |> Enum.to_list()