diff --git a/tornadis/client.py b/tornadis/client.py index 35e5a1d..411d5cc 100644 --- a/tornadis/client.py +++ b/tornadis/client.py @@ -114,6 +114,7 @@ def connect(self): db_status = yield self._call('SELECT', self.db) if db_status != b'OK': LOG.warning("can't select db %s", self.db) + self.disconnect() raise tornado.gen.Return(False) raise tornado.gen.Return(True)