Drop subs ack handling from streamer
parent
69e501764a
commit
1a291939c3
|
@ -152,19 +152,8 @@ async def stream_messages(
|
||||||
|
|
||||||
continue
|
continue
|
||||||
|
|
||||||
case {
|
|
||||||
'connectionID': _,
|
|
||||||
'event': 'systemStatus',
|
|
||||||
'status': 'online',
|
|
||||||
'version': _,
|
|
||||||
} as msg:
|
|
||||||
log.info(
|
|
||||||
'WS connection is up:\n'
|
|
||||||
f'{msg}'
|
|
||||||
)
|
|
||||||
continue
|
|
||||||
|
|
||||||
case _:
|
case _:
|
||||||
|
# passthrough sub msgs
|
||||||
yield msg
|
yield msg
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue