aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorxianny <xianny@gmail.com>2018-12-08 01:53:49 +0800
committerFred Carlsen <fred@sjelfull.no>2018-12-13 01:19:31 +0800
commitbc6492e352f573f77b0daec8f2ae58fa57dc2852 (patch)
treefa1bcc2acea3daf4667a574c33398dfa75191b9a
parent5c4a2461b87526994845f590e13650e83c68c504 (diff)
downloaddexon-sol-tools-bc6492e352f573f77b0daec8f2ae58fa57dc2852.tar.gz
dexon-sol-tools-bc6492e352f573f77b0daec8f2ae58fa57dc2852.tar.zst
dexon-sol-tools-bc6492e352f573f77b0daec8f2ae58fa57dc2852.zip
refresh rate limit every second instead of every minute
-rw-r--r--packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts6
1 files changed, 3 insertions, 3 deletions
diff --git a/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts b/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
index 0cfec4ef5..29cef65b0 100644
--- a/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
+++ b/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
@@ -52,9 +52,9 @@ export class CryptoCompareOHLCVSource {
constructor(maxReqsPerSecond: number) {
this._limiter = new Bottleneck({
minTime: ONE_SECOND / maxReqsPerSecond,
- reservoir: 2000,
- reservoirRefreshAmount: 2000,
- reservoirRefreshInterval: ONE_MINUTE,
+ reservoir: 30,
+ reservoirRefreshAmount: 30,
+ reservoirRefreshInterval: ONE_SECOND,
});
}