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

Send blank packet on no match to avoid blocking search stream

symbol_search
Tyler Goodlet 2021-05-20 10:40:34 -04:00
parent 07d8bf1453
commit a4627c2b04
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/brokers/ib.py
View File

@ -179,6 +179,7 @@ _adhoc_futes_set = {
_exch_skip_list = { _exch_skip_list = {
'ASX', # aussie stocks 'ASX', # aussie stocks
'MEXI', # mexican stocks 'MEXI', # mexican stocks
'VALUE', # no idea
} }
# https://misc.interactivebrokers.com/cstools/contract_info/v3.10/index.php?action=Conid%20Info&wlId=IB&conid=69067924 # https://misc.interactivebrokers.com/cstools/contract_info/v3.10/index.php?action=Conid%20Info&wlId=IB&conid=69067924
@ -832,7 +833,7 @@ async def get_bars(
_err = None _err = None
for _ in range(1): for _ in range(2):
try: try:
bars, bars_array = await _trio_run_client_method( bars, bars_array = await _trio_run_client_method(
@ -870,6 +871,7 @@ async def get_bars(
# and then somehow get that to trigger an event here # and then somehow get that to trigger an event here
# that restarts/resumes this task? # that restarts/resumes this task?
await tractor.breakpoint() await tractor.breakpoint()
continue
else: # throttle wasn't fixed so error out immediately else: # throttle wasn't fixed so error out immediately
raise _err raise _err
@ -1291,7 +1293,11 @@ async def open_symbol_search(
if not pattern or pattern.isspace(): if not pattern or pattern.isspace():
log.warning('empty pattern received, skipping..') log.warning('empty pattern received, skipping..')
await stream.send(matches)
# XXX: this unblocks the far end search task which may
# hold up a multi-search nursery block
await stream.send({})
continue continue
log.debug(f'searching for {pattern}') log.debug(f'searching for {pattern}')