Add some type annots around pp msg handling
							parent
							
								
									cdf9f740f7
								
							
						
					
					
						commit
						8d44706588
					
				| 
						 | 
					@ -414,6 +414,9 @@ async def open_brokerd_trades_dialogue(
 | 
				
			||||||
            )
 | 
					            )
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        try:
 | 
					        try:
 | 
				
			||||||
 | 
					            positions: list[BrokerdPosition]
 | 
				
			||||||
 | 
					            accounts: tuple[str]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            async with (
 | 
					            async with (
 | 
				
			||||||
                open_trades_endpoint as (brokerd_ctx, (positions, accounts,)),
 | 
					                open_trades_endpoint as (brokerd_ctx, (positions, accounts,)),
 | 
				
			||||||
                brokerd_ctx.open_stream() as brokerd_trades_stream,
 | 
					                brokerd_ctx.open_stream() as brokerd_trades_stream,
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -47,7 +47,7 @@ from ._position import (
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
from ._label import FormatLabel
 | 
					from ._label import FormatLabel
 | 
				
			||||||
from ._window import MultiStatus
 | 
					from ._window import MultiStatus
 | 
				
			||||||
from ..clearing._messages import Order
 | 
					from ..clearing._messages import Order, BrokerdPosition
 | 
				
			||||||
from ._forms import open_form_input_handling
 | 
					from ._forms import open_form_input_handling
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					@ -529,7 +529,12 @@ async def open_order_mode(
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    book: OrderBook
 | 
					    book: OrderBook
 | 
				
			||||||
    trades_stream: tractor.MsgStream
 | 
					    trades_stream: tractor.MsgStream
 | 
				
			||||||
    position_msgs: dict
 | 
					
 | 
				
			||||||
 | 
					    # The keys in this dict **must** be in set our set of "normalized"
 | 
				
			||||||
 | 
					    # symbol names (i.e. the same names you'd get back in search
 | 
				
			||||||
 | 
					    # results) in order for position msgs to correctly trigger the
 | 
				
			||||||
 | 
					    # display of a position indicator on screen.
 | 
				
			||||||
 | 
					    position_msgs: dict[str, list[BrokerdPosition]]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    # spawn EMS actor-service
 | 
					    # spawn EMS actor-service
 | 
				
			||||||
    async with (
 | 
					    async with (
 | 
				
			||||||
| 
						 | 
					@ -563,7 +568,9 @@ async def open_order_mode(
 | 
				
			||||||
            providers=symbol.brokers
 | 
					            providers=symbol.brokers
 | 
				
			||||||
        )
 | 
					        )
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        # use only loaded accounts according to brokerd
 | 
					        # XXX: ``brokerd`` delivers a set of account names that it allows
 | 
				
			||||||
 | 
					        # use of but the user also can define the accounts they'd like
 | 
				
			||||||
 | 
					        # to use, in order, in their `brokers.toml` file.
 | 
				
			||||||
        accounts = {}
 | 
					        accounts = {}
 | 
				
			||||||
        for name in brokerd_accounts:
 | 
					        for name in brokerd_accounts:
 | 
				
			||||||
            # ensure name is in ``brokers.toml``
 | 
					            # ensure name is in ``brokers.toml``
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue