Compare commits
1 Commits
fcf68b3fe9
...
53148b453d
Author | SHA1 | Date |
---|---|---|
|
53148b453d |
|
@ -51,6 +51,7 @@ __brokers__: list[str] = [
|
||||||
'ib',
|
'ib',
|
||||||
'kraken',
|
'kraken',
|
||||||
'kucoin',
|
'kucoin',
|
||||||
|
'deribit',
|
||||||
|
|
||||||
# broken but used to work
|
# broken but used to work
|
||||||
# 'questrade',
|
# 'questrade',
|
||||||
|
@ -61,7 +62,6 @@ __brokers__: list[str] = [
|
||||||
# wstrade
|
# wstrade
|
||||||
# iex
|
# iex
|
||||||
|
|
||||||
'deribit',
|
|
||||||
# bitso
|
# bitso
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
|
@ -31,9 +31,7 @@ from typing import (
|
||||||
Callable,
|
Callable,
|
||||||
)
|
)
|
||||||
|
|
||||||
from pendulum import (
|
from pendulum import now
|
||||||
now,
|
|
||||||
)
|
|
||||||
import trio
|
import trio
|
||||||
from trio_typing import TaskStatus
|
from trio_typing import TaskStatus
|
||||||
from rapidfuzz import process as fuzzy
|
from rapidfuzz import process as fuzzy
|
||||||
|
@ -420,6 +418,7 @@ class Client:
|
||||||
new_bars: list[tuple] = []
|
new_bars: list[tuple] = []
|
||||||
for i in range(len(result.close)):
|
for i in range(len(result.close)):
|
||||||
|
|
||||||
|
timestamp = (start_time + (i * (60 * 1000))) / 1000.0
|
||||||
_open = result.open[i]
|
_open = result.open[i]
|
||||||
high = result.high[i]
|
high = result.high[i]
|
||||||
low = result.low[i]
|
low = result.low[i]
|
||||||
|
@ -427,12 +426,12 @@ class Client:
|
||||||
volume = result.volume[i]
|
volume = result.volume[i]
|
||||||
|
|
||||||
row = [
|
row = [
|
||||||
(start_time + (i * (60 * 1000))) / 1000.0, # time
|
timestamp, # time
|
||||||
result.open[i],
|
_open,
|
||||||
result.high[i],
|
high,
|
||||||
result.low[i],
|
low,
|
||||||
result.close[i],
|
close,
|
||||||
result.volume[i]
|
volume
|
||||||
]
|
]
|
||||||
|
|
||||||
new_bars.append((i,) + tuple(row))
|
new_bars.append((i,) + tuple(row))
|
||||||
|
|
Loading…
Reference in New Issue