Remove symbol key from first quote from ib feed
parent
c9e6c81459
commit
f604437897
piker/brokers
|
@ -1472,6 +1472,7 @@ async def stream_quotes(
|
||||||
return init_msgs
|
return init_msgs
|
||||||
|
|
||||||
init_msgs = mk_init_msgs()
|
init_msgs = mk_init_msgs()
|
||||||
|
|
||||||
con = first_ticker.contract
|
con = first_ticker.contract
|
||||||
|
|
||||||
# should be real volume for this contract by default
|
# should be real volume for this contract by default
|
||||||
|
@ -1496,8 +1497,11 @@ async def stream_quotes(
|
||||||
topic = '.'.join((con['symbol'], suffix)).lower()
|
topic = '.'.join((con['symbol'], suffix)).lower()
|
||||||
quote['symbol'] = topic
|
quote['symbol'] = topic
|
||||||
|
|
||||||
|
# for compat with upcoming fqsn based derivs search
|
||||||
|
init_msgs[sym]['fqsn'] = topic
|
||||||
|
|
||||||
# pass first quote asap
|
# pass first quote asap
|
||||||
first_quote = {topic: quote}
|
first_quote = quote
|
||||||
|
|
||||||
# it might be outside regular trading hours so see if we can at
|
# it might be outside regular trading hours so see if we can at
|
||||||
# least grab history.
|
# least grab history.
|
||||||
|
|
Loading…
Reference in New Issue