def update_load(self):
        import threading
        t = threading.Thread(target=self.update_load_thread,
                           args=(self.allocated_ncpu, self.new_cpus))
        self.new_cpus = [] # DISCONNECT FROM OLD LIST TO PREVENT OVERWRITING
        t.start()
tell this coordinator to use only allocated_ncpu processors,
dataset/ETHPy150Open cjlee112/pygr/pygr/coordinator.py/CoordinatorInfo.update_load