Update scripts/cache_parallel.py: speed + balance + correctness fixes
Browse files
scripts/cache_parallel.py
CHANGED
|
@@ -30,8 +30,8 @@ def cache_chunk(args):
|
|
| 30 |
ds = OracleDataset(
|
| 31 |
data_fetcher=fetcher,
|
| 32 |
ohlc_stats_path=db_args['ohlc_stats_path'],
|
| 33 |
-
horizons_seconds=[
|
| 34 |
-
quantiles=[0.5],
|
| 35 |
)
|
| 36 |
ds.sampled_mints = [m for m in ds.sampled_mints if m['mint_address'] in return_map]
|
| 37 |
|
|
|
|
| 30 |
ds = OracleDataset(
|
| 31 |
data_fetcher=fetcher,
|
| 32 |
ohlc_stats_path=db_args['ohlc_stats_path'],
|
| 33 |
+
horizons_seconds=[30, 60, 120, 240, 420],
|
| 34 |
+
quantiles=[0.1, 0.5, 0.9],
|
| 35 |
)
|
| 36 |
ds.sampled_mints = [m for m in ds.sampled_mints if m['mint_address'] in return_map]
|
| 37 |
|