INNER CODE UNIT · Python

__init__

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

    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()

        self.lock = Lock()

View source record →