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

Drop status msg var deleting from ns

history_view
Tyler Goodlet 2022-08-30 16:26:31 -04:00
parent 55fc4114b4
commit f0d417ce42
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
piker/clearing/_ems.py
View File

@ -617,8 +617,9 @@ async def translate_and_relay_brokerd_events(
f'Received broker trade event:\n' f'Received broker trade event:\n'
f'{fmsg}' f'{fmsg}'
) )
match brokerd_msg: status_msg: Optional[Status] = None
match brokerd_msg:
# BrokerdPosition # BrokerdPosition
case { case {
'name': 'position', 'name': 'position',
@ -866,6 +867,7 @@ async def translate_and_relay_brokerd_events(
}: }:
log.error(f'Broker error:\n{fmsg}') log.error(f'Broker error:\n{fmsg}')
# XXX: we presume the brokerd cancels its own order # XXX: we presume the brokerd cancels its own order
continue
# TOO FAST ``BrokerdStatus`` that arrives # TOO FAST ``BrokerdStatus`` that arrives
# before the ``BrokerdAck``. # before the ``BrokerdAck``.
@ -894,8 +896,8 @@ async def translate_and_relay_brokerd_events(
raise ValueError(f'Brokerd message {brokerd_msg} is invalid') raise ValueError(f'Brokerd message {brokerd_msg} is invalid')
# XXX: ugh sometimes we don't access it? # XXX: ugh sometimes we don't access it?
if status_msg: # if status_msg is not None:
del status_msg # del status_msg
# TODO: do we want this to keep things cleaned up? # TODO: do we want this to keep things cleaned up?
# it might require a special status from brokerd to affirm the # it might require a special status from brokerd to affirm the