From f92a8584356565461392b62ef8c98adec8ee7455 Mon Sep 17 00:00:00 2001 From: Kalin Nonchev Date: Wed, 30 Jun 2021 20:38:39 +0200 Subject: [PATCH] delayed function --- gnomad_db/database.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gnomad_db/database.py b/gnomad_db/database.py index 18b9ba4..c30ab8e 100644 --- a/gnomad_db/database.py +++ b/gnomad_db/database.py @@ -142,8 +142,8 @@ def get_maf_from_df(self, var_df: pd.DataFrame, query: str="AF") -> pd.Series: assert len(out) == self.cpu_count delayed_get_maf_from_df = delayed(self._get_maf_from_df) - out = Parallel(self.cpu_count, prefer="threads")(delayed_get_maf_from_df(df, query) for df in out) + out = pd.concat(out) out.set_index(var_df.index, inplace=True) assert len(var_df) == len(out)