diff --git a/piker/brokers/kraken/feed.py b/piker/brokers/kraken/feed.py index 0f41a3ec..7c589d85 100644 --- a/piker/brokers/kraken/feed.py +++ b/piker/brokers/kraken/feed.py @@ -152,19 +152,8 @@ async def stream_messages( continue - case { - 'connectionID': _, - 'event': 'systemStatus', - 'status': 'online', - 'version': _, - } as msg: - log.info( - 'WS connection is up:\n' - f'{msg}' - ) - continue - case _: + # passthrough sub msgs yield msg