diff --git a/lib/growth/indicators/download.ex b/lib/growth/indicators/download.ex index 14b2d76..bc24dbe 100644 --- a/lib/growth/indicators/download.ex +++ b/lib/growth/indicators/download.ex @@ -205,13 +205,17 @@ defmodule Growth.Indicators.Download do |> Task.await_many() end - def process_measure( - {measure, - %{ - female: %{age_tables: female_urls, expanded_tables: e_female_urls}, - male: %{age_tables: male_urls, expanded_tables: e_male_urls} - }} - ) do + def process_measure({measure, urls}) do + urls + |> process_genders() + |> as_csv() + |> save(measure) + end + + def process_genders(%{ + female: %{age_tables: female_urls, expanded_tables: e_female_urls}, + male: %{age_tables: male_urls, expanded_tables: e_male_urls} + }) do [ {:female, :age, female_urls}, {:male, :age, male_urls}, @@ -221,8 +225,6 @@ defmodule Growth.Indicators.Download do |> Enum.map(&Task.async(__MODULE__, :process_gender, [&1])) |> Task.await_many() |> merge() - |> as_csv() - |> save(measure) end def process_gender({gender, category, urls}) do