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

Move headless notifies into `.client_broadcast()`

offline_dark_clearing
Tyler Goodlet 2022-10-05 14:25:47 -04:00
parent 2fbfe583dd
commit 3924c66bd0
1 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
piker/clearing/_ems.py
View File

@ -216,6 +216,7 @@ async def clear_dark_triggers(
brokerd_msg: Optional[BrokerdOrder] = None brokerd_msg: Optional[BrokerdOrder] = None
match cmd: match cmd:
# alert: nothing to do but relay a status # alert: nothing to do but relay a status
# back to the requesting ems client # back to the requesting ems client
case Order(action='alert'): case Order(action='alert'):
@ -245,7 +246,6 @@ async def clear_dark_triggers(
price=submit_price, price=submit_price,
size=size, size=size,
) )
await brokerd_orders_stream.send(brokerd_msg) await brokerd_orders_stream.send(brokerd_msg)
case _: case _:
@ -551,6 +551,7 @@ class Router(Struct):
self, self,
sub_key: str, sub_key: str,
msg: dict, msg: dict,
notify_on_headless: bool = True,
) -> bool: ) -> bool:
to_remove: set[tractor.MsgStream] = set() to_remove: set[tractor.MsgStream] = set()
@ -578,6 +579,18 @@ class Router(Struct):
if to_remove: if to_remove:
subs.difference_update(to_remove) subs.difference_update(to_remove)
if (
not sent_some
and notify_on_headless
):
log.info(
'No clients attached, firing notification for msg:\n'
f'{msg}'
)
await notify_from_ems_status_msg(
msg,
is_subproc=True,
)
return sent_some return sent_some
@ -781,20 +794,10 @@ async def translate_and_relay_brokerd_events(
status_msg.brokerd_msg = msg status_msg.brokerd_msg = msg
status_msg.src = msg.broker_details['name'] status_msg.src = msg.broker_details['name']
sent_some = await router.client_broadcast( await router.client_broadcast(
status_msg.req.symbol, status_msg.req.symbol,
status_msg, status_msg,
) )
if not sent_some:
log.info(
'No clients attached, firing notification for msg:\n'
f'{fmsg}'
)
await notify_from_ems_status_msg(
oid,
status_msg,
is_subproc=True,
)
if status == 'closed': if status == 'closed':
log.info(f'Execution for {oid} is complete!') log.info(f'Execution for {oid} is complete!')