diff --git a/momoko/pools.py b/momoko/pools.py index 91cc43b..407ecae 100644 --- a/momoko/pools.py +++ b/momoko/pools.py @@ -318,8 +318,8 @@ def cursor(self, function, function_args, callback, cursor_kwargs={}): getattr(cursor, function)(*function_args) self._callbacks = [partial(callback, cursor)] - # Connection state should be 1 (write) - self._ioloop.update_handler(self._fileno, IOLoop.READ) + # Fire callback immediately To correctly set the update handler + self._io_callback(None, None) def _io_callback(self, fd, events): try: