delayed function

KalinNonchev · Jun 30, 2021 · f92a858 · f92a858
1 parent 9595152
commit f92a858
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)