Handle broken connection

Test with `test/fault_tolerance.py` (assumes redis can be started/stopped with `sudo redis-server start/stop`)