diff --git a/piker/brokers/kraken/feed.py b/piker/brokers/kraken/feed.py index 5ea96e28..a54329db 100644 --- a/piker/brokers/kraken/feed.py +++ b/piker/brokers/kraken/feed.py @@ -189,6 +189,17 @@ async def process_data_feed_msgs( # chan_id, *payload_array, chan_name, pair = msg # print(msg) + case { + 'connectionID': conid, + 'event': 'systemStatus', + 'status': 'online', + 'version': ver, + }: + log.info( + f'Established {ver} ws connection with id: {conid}' + ) + continue + case _: print(f'UNHANDLED MSG: {msg}') # yield msg