assert isinstance(future, IOLoop._FUTURE_TYPES)
callback = stack_context.wrap(callback)
future.add_done_callback(
- lambda future: self.add_callback(
- functools.partial(callback, future)))
+ lambda future: self.add_callback(callback, future))
def _run_callback(self, callback):
"""Runs a callback with error handling.
assert ret_pid == pid
subproc = cls._waiting.pop(pid)
subproc.io_loop.add_callback_from_signal(
- functools.partial(subproc._set_returncode, status))
+ subproc._set_returncode, status)
def _set_returncode(self, status):
if os.WIFSIGNALED(status):