INNER CODE UNIT · Python

cb

autokitteh/autokitteh · runtimes/pythonrt/runner/main.py:333

        def cb(fut):
            log.info("execution on threadpool done: %s", full_func_name(fn))
            if exc := fut.exception():
                log.error(
                    "Uncaught exception in executor: %r, traceback: %s",
                    exc,
                    format_exception(exc),
                )
                force_close(self.server)

        fut = self.executor.submit(fn, *args, **kw)
        fut.add_done_callback(cb)

        return fut

    def stop_if_start_not_called(self, timeout):
        log.error("Start not called after %s seconds, terminating", timeout)
        if self.server:

View source record →