def _callback(self, cassandra_future, tornado_future):
        """Cassandra async I/O loop callback handler."""
        try:
            result = cassandra_future.result()
        except Exception as exc:
            return tornado_future.set_exception(exc)
        tornado_future.set_result(result)