pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Strengthen retry case and add comments

small_kucoin_fixes
jaredgoldman 2023-03-20 21:24:23 -04:00
parent 7bdebd47d1
commit 32107d0ac3
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
piker/brokers/kucoin.py
View File

@ -343,6 +343,7 @@ class Client:
url = f"/market/candles?type={type}&symbol={kucoin_sym}&startAt={start_dt}&endAt={end_dt}" url = f"/market/candles?type={type}&symbol={kucoin_sym}&startAt={start_dt}&endAt={end_dt}"
bars = [] bars = []
for i in range(10): for i in range(10):
res = await self._request( res = await self._request(
@ -350,7 +351,9 @@ class Client:
url, url,
api_v="v1", api_v="v1",
) )
if not isinstance(res, list):
if not isinstance(res, list) or not len(bars):
# Do a gradual backoff if Kucoin is rate limiting us
await trio.sleep(i + (randint(0, 1000) / 1000)) await trio.sleep(i + (randint(0, 1000) / 1000))
else: else:
bars = res bars = res