INNER CODE UNIT · Python

Runner

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

class Runner(pb.runner_rpc.RunnerService):
    def __init__(
        self,
        id,
        worker,
        code_dir,
        server,
        large_objects_manager: LargeObjectsManager,
        start_timeout=DEFAULT_START_TIMEOUT,
    ):
        self.id = id
        self.worker: pb.handler_rpc.HandlerServiceStub = worker
        self.code_dir = code_dir
        self.server: grpc.Server = server

        # DO NOT USE DIRECTLY. Use submit_to_threadpool().
        self.executor = ThreadPoolExecutor()

View source record →