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

Only update pnl label on quotes with an fqsn match

pre_viz_calls
Tyler Goodlet 2022-11-14 17:06:48 -05:00
parent 9c08ad105d
commit e7f4340fe1
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
piker/ui/_position.py
View File

@ -80,9 +80,9 @@ async def update_pnl_from_feed(
''' '''
global _pnl_tasks global _pnl_tasks
pp = order_mode.current_pp pp: PositionTracker = order_mode.current_pp
live = pp.live_pp live: Position = pp.live_pp
key = live.symbol.front_fqsn() key: str = live.symbol.front_fqsn()
log.info(f'Starting pnl display for {pp.alloc.account}') log.info(f'Starting pnl display for {pp.alloc.account}')
@ -101,12 +101,18 @@ async def update_pnl_from_feed(
async with flume.stream.subscribe() as bstream: async with flume.stream.subscribe() as bstream:
# last_tick = time.time() # last_tick = time.time()
async for quotes in bstream: async for quotes in bstream:
# now = time.time() # now = time.time()
# period = now - last_tick # period = now - last_tick
for sym, quote in quotes.items(): for sym, quote in quotes.items():
# TODO: uggggh we probably want a better state
# management then this sincce we want to enable
# updating whatever the current symbol is in
# real-time right?
if sym != key:
continue
for tick in iterticks(quote, types): for tick in iterticks(quote, types):
# print(f'{1/period} Hz') # print(f'{1/period} Hz')
@ -119,6 +125,7 @@ async def update_pnl_from_feed(
else: else:
# compute and display pnl status # compute and display pnl status
# print(f'formatting PNL {sym}: {quote}')
order_mode.pane.pnl_label.format( order_mode.pane.pnl_label.format(
pnl=copysign(1, size) * pnl( pnl=copysign(1, size) * pnl(
# live.ppu, # live.ppu,