pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

save progress on kraken to test out unit_select_fixes

kraken_orders
Konstantine Tsafatinos 2021-11-04 14:34:43 -04:00
parent 48c7b5262c
commit 3d2be3674e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
piker/brokers/kraken.py
View File

@ -40,7 +40,7 @@ from ._util import resproc, SymbolNotFound, BrokerError
from ..log import get_logger, get_console_log from ..log import get_logger, get_console_log
from ..data import ShmArray from ..data import ShmArray
from ..data._web_bs import open_autorecon_ws from ..data._web_bs import open_autorecon_ws
from ..clearing._messages import BrokerdPosition from ..clearing._messages import BrokerdPosition, BrokerdOrder, BrokerdStatus
import urllib.parse import urllib.parse
import hashlib import hashlib
@ -455,7 +455,8 @@ async def trades_dialogue(
msg = pack_position(acc_name, norm_sym, pos, vols[ticker]) msg = pack_position(acc_name, norm_sym, pos, vols[ticker])
all_positions.append(msg.dict()) all_positions.append(msg.dict())
#await tractor.breakpoint() open_orders = await client.get_user_data('OpenOrders', {})
await tractor.breakpoint()
await ctx.started((all_positions, (acc_name,))) await ctx.started((all_positions, (acc_name,)))