diff --git a/piker/brokers/ib/broker.py b/piker/brokers/ib/broker.py index cd4dc5d3..3a283254 100644 --- a/piker/brokers/ib/broker.py +++ b/piker/brokers/ib/broker.py @@ -1348,6 +1348,9 @@ async def deliver_trade_events( }: pcc: str = "Peer closed connection." if pcc in err: + # TODO, emit and raise? + # [ ] try for reconnect? + # raise BrokerdError( await tractor.pause() log.error(