Set `.bs_mktid` on all IB position-msg emissions..
							parent
							
								
									9ea857298c
								
							
						
					
					
						commit
						ad3fe65bd9
					
				|  | @ -358,6 +358,10 @@ async def update_and_audit_pos_msg( | |||
|         size=ibpos.position, | ||||
| 
 | ||||
|         avg_price=pikerpos.ppu, | ||||
| 
 | ||||
|         # XXX ensures matching even if multiple venue-names | ||||
|         # in `.bs_fqme`, likely from txn records.. | ||||
|         bs_mktid=mkt.bs_mktid, | ||||
|     ) | ||||
| 
 | ||||
|     ibfmtmsg: str = pformat(ibpos._asdict()) | ||||
|  | @ -426,7 +430,8 @@ async def aggr_open_orders( | |||
| 
 | ||||
| ) -> None: | ||||
|     ''' | ||||
|     Collect all open orders from client and fill in `order_msgs: list`. | ||||
|     Collect all open orders from client and fill in `order_msgs: | ||||
|     list`. | ||||
| 
 | ||||
|     ''' | ||||
|     trades: list[Trade] = client.ib.openTrades() | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue