def add_worker(self, worker):
        if worker in self.workers:
            return
        
        # rpc call the other workers to add this worker
        for node in self.workers:
            client_call(node, 'add_node', worker)
        self.workers.append(worker)
dataset/ETHPy150Open chineking/cola/cola/cluster/master.py/JobMaster.add_worker/original