diff options
| -rw-r--r-- | python/analytics/index_data.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/analytics/index_data.py b/python/analytics/index_data.py index f2069e8e..391103a0 100644 --- a/python/analytics/index_data.py +++ b/python/analytics/index_data.py @@ -176,7 +176,7 @@ def build_curves(quotes, args): def build_curves_dist(quotes, args, workers=4): - # about twice as fast as the non distributed version + # about twice as *slow* as the non distributed version # non thread safe for some reason so need ProcessPool with Pool(workers) as pool: r = pool.starmap(build_curve, [(q, *args) for q in quotes], 30) @@ -188,7 +188,7 @@ def _get_singlenames_curves(index_type, series, trade_date, tenors): sn_quotes = get_singlenames_quotes(f"{index_type.lower()}{series}", trade_date, tenors) args = (np.array(tenors, dtype='float'),) - return build_curves_dist(sn_quotes, args) + return build_curves(sn_quotes, args) def get_singlenames_curves(index_type, series, trade_date, |