[WIP] Implement growth assessment using WHO indicators #80
@ -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
|
||||
|
Loading…
x
Reference in New Issue
Block a user