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

Fix var name typo

windows_fixes_yo
Tyler Goodlet 2022-02-04 14:52:45 -05:00
parent 5274eb538c
commit e4244e96a9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
piker/data/_sampling.py
View File

@ -252,7 +252,7 @@ async def sample_and_broadcast(
try: try:
stream.send_nowait((sym, quote)) stream.send_nowait((sym, quote))
except trio.WouldBlock: except trio.WouldBlock:
ctx = getattr(sream, '_ctx', None) ctx = getattr(stream, '_ctx', None)
if ctx: if ctx:
log.warning( log.warning(
f'Feed overrun {bus.brokername} ->' f'Feed overrun {bus.brokername} ->'
@ -371,7 +371,7 @@ async def uniform_rate_send(
# we have a quote already so send it now. # we have a quote already so send it now.
measured_rate = 1 / (time.time() - last_send) # measured_rate = 1 / (time.time() - last_send)
# log.info( # log.info(
# f'`{sym}` throttled send hz: {round(measured_rate, ndigits=1)}' # f'`{sym}` throttled send hz: {round(measured_rate, ndigits=1)}'
# ) # )